以下の手順を使用して、Kafka connect-test トピックにデータを入力しようとしました。トピックを 1 回使用することができましたが、新しいファイルで 2 回目の試みを行ったところ、データを使用できませんでした。出力ファイルtest.sink.txt
が更新されない
echo -e "foo\nbar" > test.txt
bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic connect-test --from-beginning
-rw-rw-r-- 1 kafka kafka 8 Jan 27 20:41 test.txt -rw-rw-r-- 1 kafka kafka 0 Jan 27 20:42 test.sink.txt