我是Kafka的新人。我刚刚通过引用confluent doc/guide中的步骤配置了一个kafka独立连接器。
kafka连接器的工作是同步文件-test.txt中的数据。如果我更新test.txt中的任何内容，它不会自动推送到主题连接测试，而如果我重新启动连接器，则会检测到test.txt中更新的消息并将其推送到主题连接测试。
所以，我的疑问是，我是否必须安排这个连接器来检测更改，或者它会根据某个时间间隔在内部自动完成这项工作。
我是Kafka的新人。我刚刚通过引用confluent doc/guide中的步骤配置了一个kafka独立连接器。
kafka连接器的工作是同步文件-test.txt中的数据。如果我更新test.txt中的任何内容，它不会自动推送到主题连接测试，而如果我重新启动连接器，则会检测到test.txt中更新的消息并将其推送到主题连接测试。
所以，我的疑问是，我是否必须安排这个连接器来检测更改，或者它会根据某个时间间隔在内部自动完成这项工作。
1条答案
按热度按时间sirbozc51#
简单回答：正在运行的连接器会自动同步。
如果我没听错的话，你想要文件的内容
text.txt被推送到Kafka，因此，允许您的Kafka连接器从中读取新的数据。启动一个新的生产者，它会将文件内容推送到您的主题：
添加新邮件：
这个信息会出现在主题中。
如果kafka连接器正在运行并且配置正确，它将从主题中检索消息。