我是kafka connect的新手。我在服务器上配置了一个接收器连接器,用于将数据从kafka队列发送到弹性搜索。我创建了一个项目来生成kafka队列的数据。这是成功的,因为当我尝试使用Kafka消费者消费数据时,我可以看到数据。现在,我需要在我的Java项目中做什么配置,以便启动接收器连接器,并将数据从Kafka队列转移到弹性搜索。或者,这应该是自动发生的,因为连接器配置已经指向elk-url,其他配置也已经到位?
Kafka Connect是一项服务/任务,就像Kafka Broker是一项任务一样,您需要确保您的Kafka Connection(Worker(已启动并运行您配置的连接器正在Kafka Connect服务中运行
Kafka Connect公开REST API以检查连接器状态