How can Kafka mqtt connector send mqtt topic as key?











up vote
0
down vote

favorite












I have a MQTT broker and a Kafka broker running, I have used the kafka-connector: https://github.com/Landoop/stream-reactor, with the next configuration:



name=Mqtt-Source

connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector

tasks.max=1

connect.mqtt.kcql=INSERT INTO test SELECT * FROM + WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter` WITHKEY(id)

connect.mqtt.connection.clean=true

connect.mqtt.connection.timeout=1000

connect.mqtt.connection.keep.alive=1000

connect.mqtt.client.id=test_mqtt_connector

connect.mqtt.converter.throw.on.error=true

connect.mqtt.hosts=tcp://mqtt-broker:1883

connect.mqtt.service.quality=1


In the kcql, I'm definning the field of the message that kafka should take as key, is it anyway to use the mqtt-topic as key? So I don't need to define the WITHKEY() in the kcql.






apache-kafka mqtt apache-kafka-connect







share|improve this question


























    up vote
    0
    down vote

    favorite












    I have a MQTT broker and a Kafka broker running, I have used the kafka-connector: https://github.com/Landoop/stream-reactor, with the next configuration:



    name=Mqtt-Source
    
connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
    
tasks.max=1
    
connect.mqtt.kcql=INSERT INTO test SELECT * FROM + WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter` WITHKEY(id)
    
connect.mqtt.connection.clean=true
    
connect.mqtt.connection.timeout=1000
    
connect.mqtt.connection.keep.alive=1000
    
connect.mqtt.client.id=test_mqtt_connector
    
connect.mqtt.converter.throw.on.error=true
    
connect.mqtt.hosts=tcp://mqtt-broker:1883
    
connect.mqtt.service.quality=1


    In the kcql, I'm definning the field of the message that kafka should take as key, is it anyway to use the mqtt-topic as key? So I don't need to define the WITHKEY() in the kcql.






    apache-kafka mqtt apache-kafka-connect







    share|improve this question
























      up vote
      0
      down vote

      favorite









      up vote
      0
      down vote

      favorite











      I have a MQTT broker and a Kafka broker running, I have used the kafka-connector: https://github.com/Landoop/stream-reactor, with the next configuration:



      name=Mqtt-Source
      
connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
      
tasks.max=1
      
connect.mqtt.kcql=INSERT INTO test SELECT * FROM + WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter` WITHKEY(id)
      
connect.mqtt.connection.clean=true
      
connect.mqtt.connection.timeout=1000
      
connect.mqtt.connection.keep.alive=1000
      
connect.mqtt.client.id=test_mqtt_connector
      
connect.mqtt.converter.throw.on.error=true
      
connect.mqtt.hosts=tcp://mqtt-broker:1883
      
connect.mqtt.service.quality=1


      In the kcql, I'm definning the field of the message that kafka should take as key, is it anyway to use the mqtt-topic as key? So I don't need to define the WITHKEY() in the kcql.






      apache-kafka mqtt apache-kafka-connect







      share|improve this question













      I have a MQTT broker and a Kafka broker running, I have used the kafka-connector: https://github.com/Landoop/stream-reactor, with the next configuration:



      name=Mqtt-Source
      
connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
      
tasks.max=1
      
connect.mqtt.kcql=INSERT INTO test SELECT * FROM + WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter` WITHKEY(id)
      
connect.mqtt.connection.clean=true
      
connect.mqtt.connection.timeout=1000
      
connect.mqtt.connection.keep.alive=1000
      
connect.mqtt.client.id=test_mqtt_connector
      
connect.mqtt.converter.throw.on.error=true
      
connect.mqtt.hosts=tcp://mqtt-broker:1883
      
connect.mqtt.service.quality=1


      In the kcql, I'm definning the field of the message that kafka should take as key, is it anyway to use the mqtt-topic as key? So I don't need to define the WITHKEY() in the kcql.






      apache-kafka mqtt apache-kafka-connect




      apache-kafka mqtt apache-kafka-connect






      share|improve this question













      share|improve this question











      share|improve this question




      share|improve this question










      asked 5 hours ago









      Asier Gomez

      1,34672056




      1,34672056





























          active

          oldest

          votes











          Your Answer






          StackExchange.ifUsing("editor", function () {
          StackExchange.using("externalEditor", function () {
          StackExchange.using("snippets", function () {
          StackExchange.snippets.init();
          });
          });
          }, "code-snippets");

          StackExchange.ready(function() {
          var channelOptions = {
          tags: "".split(" "),
          id: "1"
          };
          initTagRenderer("".split(" "), "".split(" "), channelOptions);

          StackExchange.using("externalEditor", function() {
          // Have to fire editor after snippets, if snippets enabled
          if (StackExchange.settings.snippets.snippetsEnabled) {
          StackExchange.using("snippets", function() {
          createEditor();
          });
          }
          else {
          createEditor();
          }
          });

          function createEditor() {
          StackExchange.prepareEditor({
          heartbeatType: 'answer',
          convertImagesToLinks: true,
          noModals: true,
          showLowRepImageUploadWarning: true,
          reputationToPostImages: 10,
          bindNavPrevention: true,
          postfix: "",
          imageUploader: {
          brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
          contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
          allowUrls: true
          },
          onDemand: true,
          discardSelector: ".discard-answer"
          ,immediatelyShowMarkdownHelp:true
          });


          }
          });














           

          draft saved


          draft discarded


















          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53370576%2fhow-can-kafka-mqtt-connector-send-mqtt-topic-as-key%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown






























          active

          oldest

          votes













          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes
















           

          draft saved


          draft discarded



















































           


          draft saved


          draft discarded














          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53370576%2fhow-can-kafka-mqtt-connector-send-mqtt-topic-as-key%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown





















































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown

































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown







          -

          Popular posts from this blog

          Volksrepublik China

          Image
          Dieser Artikel befasst sich mit der Volksrepublik China und ist nicht zu verwechseln mit der Republik China (Taiwan). Siehe auch China (Begriffsklärung). Dieser Artikel wurde aufgrund von inhaltlichen Mängeln auf der Qualitätssicherungsseite der Redaktion Ostasien eingetragen. Dies geschieht, um die Qualität der Artikel aus dem Themengebiet Ostasien auf ein akzeptables Niveau zu bringen. Dabei werden Artikel gelöscht, die nicht signifikant verbessert werden können. Bitte hilf mit, die inhaltlichen Mängel dieses Artikels zu beseitigen, und beteilige dich bitte an der Diskussion ! 中华人民共和国 Zhōnghuá Rénmín Gònghéguó Volksrepublik China Flagge Emblem Amtssprache Chinesisch (Hochchinesisch) und anerkannte Regionalsprachen 1 Hauptstadt Peking Staatsform Republik Regierungssystem Sozialistisches Einparteiensystem Staatsoberhaupt Staatspräsident Xi Jinping Regierungschef Ministerpräsident Li Keqiang Fläc...
          Read more

          How to test boost logger output in unit testing?

          Image
          up vote 1 down vote favorite My application uses BOOST_LOG_TRIVIAL to log messages. I thought it's good to check in test (gtest) that correct messages are written there in given scenarios. Is there a way to somehow access what was written there after code was called? Or does it first have to be mocked in some way? I have googled a lot for this and haven't found any instructions, so either I am asking wrong questions or no one thinks it should be done. c++ logging boost googletest boost-log share | improve this question edited yesterday ...
          Read more

          How do you send bulk inserts with no ids to elasticsearch

          Image
          up vote 0 down vote favorite I'm trying to use the bulk inset api for elastic search. I would like to insert documents with auto generated IDs but I'm just getting errors no matter what i try. Here are a few example efforts: http://localhost:9200/_bulk {"create": {"_index": "test", "_type": "_doc"} } {"user": "kimchy", "post_date": "2002-11-15T14:12:12", "message": "trying out Elasticsearch"} Both put and post give the error: { "error": { "root_cause": [ { "type": "action_request_validation_exception", "reason": "Validation Failed: 1: an id must be provided if version type or value are set;" } ], ...
          Read more