0

我一直在使用以下指南将 Kafka connect 用于融合平台

Kafka 连接快速入门

但是它不再更新 sink 文件，源文件中的任何更改都不会写入 kafka 主题中。

我已经删除了所有 tmp 文件，但没有任何变化。

提前致谢

4

4 回答 4

1

使用用于存储偏移的新位置启动新的文件源连接器。这个连接器是一个演示，除了一个只获取附加更新的简单文件之外，它实际上不处理任何东西。请注意，除了简单的演示之外，您不应使用此连接器做任何事情。如果您需要用于生产的东西，请查看连接器集线器。

于 2016-10-01T17:21:50.393 回答
0

我以前也遇到过同样的问题。但是如下更正属性文件中输入和输出文件的路径对我有用。它从输入文件（test.txt）流向输出文件（test.sink.txt）。

name=local-file-source
connector.class=FileStreamSource
tasks.max=1
file=/home/mypath/kafka/test.txt
topic=connect-test

name=local-file-sink
connector.class=FileStreamSink
tasks.max=1
file=/home/mypath/kafka/test.sink.txt
topics=connect-test
于 2019-03-11T07:33:18.573 回答
0

对于 OP，我在 5 分钟前就遇到过这种情况，但是当我重新启动连接器时，一切都很好，test.sink.txt 和消费者都添加了新行。所以简而言之，只需重新启动连接器。

于 2017-07-27T12:01:08.563 回答
0

FileStreamSource/Sink在它工作正常并且你已经重新启动了 zookeeper、kafka 服务器和连接器后不起作用，但它仍然不起作用，那么问题在于 kafka 目录中的CONNECT.OFFSETS文件。您应该删除它并创建一个新的空的。

于 2018-03-27T19:37:13.843 回答