diff --git a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java index e2df8b6..ece270c 100644 --- a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java +++ b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java @@ -89,8 +89,15 @@ public class MqttTest { .value(value) .type("String") .build()); + kafKaDataList.add(KafKaData.builder() + .key("firmCode") + .label("企业编码") + .value("firm01") + .type("String") + .build()); } String jsonString = JSONObject.toJSONString(kafKaDataList); + ProducerRecord producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString); kafkaProducer.send(producerRecord); log.info("kafka投产:{}", jsonString); @@ -100,6 +107,8 @@ public class MqttTest { // System.out.println(jsonString); } + + // 接收信息 @Override public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {