0

以下の手順を使用して、Kafka connect-test トピックにデータを入力しようとしました。トピックを 1 回使用することができましたが、新しいファイルで 2 回目の試みを行ったところ、データを使用できませんでした。出力ファイルtest.sink.txtが更新されない

  1. echo -e "foo\nbar" > test.txt

  2. bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

  3. 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
    
4

1 に答える 1