我是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连接器正在运行并且配置正确,它将从主题中检索消息。