Kafka Connect: test.sink.txt не обновляется после запуска коннекторов и потребителя

Question

Я попытался ввести данные в тему подключения к Kafka, используя приведенные ниже шаги. Я смог использовать тему один раз и при второй попытке с новым файлом , Я не могу получить данные. Выходной файл test.sink.txt не получает обновленный

Шаг1: эхо -e "Foo \ NBAR"> test.txt

Step2: бен/connect-standalone.sh конфигурации/connect-standalone.properties конфигурации /connect-file-source.properties конфигурации/connect-file-sink.properties

Step3: бен/kafka-console-consumer.sh --zookeeper локальный: 2181 --topic подключения тест---from начиная

-rw-rw-r-- 1 kafka kafka 8 янв 27 20:41 test.txt -rw-rw-r-- 1 kafka kafka 0 27 янв. 20:42 test.sink.txt

Answer 1

Похожие вопрос ответил здесь: Kafka connect tutorial stopped working

Исходный файл Кафка подключения сохраняет последнее место чтения из файла. Когда вы удалили файл без сброса смещений на 0, соединитель ожидает появления новых данных, начиная с определенного количества символов с самого начала.

Если вы используете автономный режим, то удаление /tmp/connect.offsets решит проблему.