Автономный ли разъем Kafka синхронизируется автоматически или его нужно перезагружать каждый раз?

Question

Я новичок в Кафке. Я только что настроил один автономный разъем Kafka, ссылаясь на шаги из слияния doc / guide .

Работа коннектора Kafka заключается в синхронизации данных из файла - test.txt. Если я обновляю что-либо в test.txt, он автоматически не выдвигается в раздел - connect-test, тогда как при перезапуске коннектора обновленные сообщения из test.txt обнаруживаются и передаются в раздел - connect-test.

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

Answer 1

Краткий ответ: работающий разъем синхронизируется автоматически .

Если я вас правильно понимаю, вы хотите, чтобы содержимое вашего файла text.txt было отправлено в kafka, что позволит вашему kafka-соединителю читать новые данные из него.

Запустите нового производителя, который будет загружать содержимое файла в вашу тему:

$ kafka-console-producer.sh --broker-list localhost:9092 --topic connect-test
--new-producer < text.txt

Добавление новых сообщений:

$ echo "new message" >> text.txt

И это сообщение появится в теме.

Если ваш kafka-соединитель работает и настроен правильно, он будет получать сообщения из темы.