parent
2dcc74f546
commit
481f9e3e3b
|
@ -34,10 +34,10 @@ public class MessageCallbackService implements MqttCallback {
|
||||||
String s = new String(mqttMessage.getPayload());
|
String s = new String(mqttMessage.getPayload());
|
||||||
MessageData main = ConversionUtil.main(s);
|
MessageData main = ConversionUtil.main(s);
|
||||||
String vin = main.getVin();
|
String vin = main.getVin();
|
||||||
|
ProducerRecord<String, String> stringObjectProducerRecord = new ProducerRecord<>(vin,main.toString());
|
||||||
ProducerRecord<String, Object> stringObjectProducerRecord = new ProducerRecord<>("test",main);
|
|
||||||
kafkaTemplate.send(stringObjectProducerRecord);
|
kafkaTemplate.send(stringObjectProducerRecord);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue