2016-09-07 5 views
0

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

Kafka connect quickstart

Но не обновляет файл раковины больше, какие-либо изменения в исходном файле не написаны в теме кафки.

Я уже удалил все файлы tmp, но без изменений.

Заранее спасибо

ответ

1

Запуск нового соединителя источника файла с новым местом для хранения смещения. Этот коннектор предназначен как демонстрационный пример и действительно не обрабатывает ничего, кроме простого файла, который получает только обновления. Обратите внимание: вы не должны ничего делать с этим коннектором, кроме простой демонстрации. Посмотрите на концентратор соединителя, если вам нужно что-то для производства.

0

К OP, у меня было это как 5 минут назад, но когда я перезапустил разъем, все нормально, и test.sink.txt, и потребитель получают новую строку. Итак, вкратце, просто перезапустите свой разъем.