具有多个主题的 Kafka MQTT 连接器

Question

我们正在使用Confluent团队的Kafka-Mqtt连接器。有没有办法将数据从多个 Mqtt 主题发布到与Mqtt同名的多个 Kafka 主题，即 Mqtt 中的 test1 -> kafka 中的 test1，依此类推。?

Answer 1

您可以运行多个 MQTT 源连接器，以便从不同的主题复制数据：

例如

{
"config" : {
"name" : "MqttSourceConnector1",
"connector.class" : "io.confluent.connect.mqtt.MqttSourceConnector",
"tasks.max" : "1",
"mqtt.server.uri" : "< Required Configuration >",
"mqtt.topics" : "topic_1"
}
}

和

{
"config" : {
"name" : "MqttSourceConnector2",
"connector.class" : "io.confluent.connect.mqtt.MqttSourceConnector",
"tasks.max" : "1",
"mqtt.server.uri" : "< Required Configuration >",
"mqtt.topics" : "topic_2"
}
}