参考https://stackoverflow.com/questions/35049287/kafka-connect-test-sink-txt-is-not-getting-updated-after-running-connectors-an
执行bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties，发现test.sink.txt并没有更新。
因为之前手动删了test.sink.txt文件，offset没有重置，所以读不出内容。将/tmp/connect.offsets删除即可。
没有评论:
发表评论