Kafka MQTT разъем с несколькими темами

Question

Мы используем соединитель Kafka-Mqtt от команды Confluent. Есть ли способ опубликовать данные из нескольких тем Mqtt до нескольких тем Kafka с тем же именем, что и у Mqtt, т.е. test1 в Mqtt -> test1 в kafka и так далее.

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"
      }
    }