我已经尝试使用以下步骤将数据输入到kafka connect测试主题中。我可以使用一次主题，第二次尝试使用新文件时，我无法使用数据。未更新输出文件test.sink.txt
第1步：echo-e“foo\nbar”>test.txt
步骤2:bin/connect-standalone.sh config/connect-standalone.properties配置/connect-file-source.properties配置/connect-file-sink.properties
步骤3:bin/kafka-console-consumer.sh--zookeeperlocalhost:2181 --topic 连接测试--从头开始
-rw-rw-r--1KafkaKafka8 jan 27 20:41 test.txt-rw-rw-r--1KafkaKafka0 jan 27 20:42 test.txt
1条答案
按热度按时间cnwbcb6i1#
类似的问题在这里得到了回答：Kafka连接教程停止工作
kafka文件源连接保留文件的最后读取位置。删除文件而不将偏移量重置为0时，连接器将等待新数据从开始的特定字符计数开始显示。
如果您使用的是独立模式，那么删除/tmp/connect.offset可以解决这个问题。