Kafka独立连接器是否自动同步或每次都需要重新启动

Question

我是卡夫卡的新手。我刚刚通过参考 confluent doc/guide 中的步骤配置了一个 Kafka 独立连接器。

Kafka 连接器的工作是从文件-test.txt 同步数据。 如果我更新 test.txt 中的任何内容，它不会自动推送到主题 - 连接测试，而如果我重新启动连接器，来自 test.txt 的更新消息会被检测到并推送到主题 - 连接测试。

所以，我怀疑我是否必须安排此连接器来检测更改，或者它会根据某个时间间隔在内部自动执行此工作。

Answer 1

简答：正在运行的连接器会自动同步。

如果我理解正确，您希望将文件 text.txt 的内容推送到 kafka，从而允许您的 kafka-connector 从中读取新的 dato。

启动一个新的生产者，它将文件内容推送到您的主题：

$ kafka-console-producer.sh --broker-list localhost:9092 --topic connect-test
--new-producer < text.txt

添加新消息：

$ echo "new message" >> text.txt

并且此消息将显示在主题中。

如果您的 kafka-connector 正在运行并正确配置，它将从主题中检索消息。