Мойка Kafka MQTT не может пересылать на разные темы - PullRequest
Новая
       16

Мойка Kafka MQTT не может пересылать на разные темы

0 голосов
/ 07 января 2019

Я пытаюсь отправлять сообщения MQTT на разные темы с помощью Kafka. Я использую Confluent MqttSinkConnector, и моя конфигурация коннектора выглядит следующим образом 

{
"name" : "mqttSinkConnector",
"config" : {
    "connector.class": "io.confluent.connect.mqtt.MqttSinkConnector",
    "tasks.max": "1",
    "mqtt.server.uri": "tcp://mqttServer:1883",
    "topics":"mqttSink",
    "mqtt.qos": "1",
    "mqtt.username": "user",
    "mqtt.password": "pass",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "value.converter": "org.apache.kafka.connect.storage.StringConverter",
    "confluent.topic.bootstrap.servers": "kafkaServer:9092",
    "confluent.topic.replication.factor": "1"
}}

Я отправляю тестовые сообщения в тему "mqttSink" Kafka с разными ключами, но все они в конечном итоге попадают в тему "mqttSink" в брокере Mqtt. Как я понял, он должен был попасть в тему "/ t1". Есть ли способ опубликовать в различных темах Mqtt из Kafka.

Тест производителей, которые я пробовал; 

# python confluent-kafka producer
p.produce('mqttSink', value=testStr, key=b'/t1')
# python kafka producer
producer.send("mqttSink",key=b'/t1', value=testStr).get(timeout=30)
...