|
@@ -36,7 +36,6 @@ public class KafkaCloudConsumer {
|
|
|
* @param record 消息记录
|
|
* @param record 消息记录
|
|
|
*/
|
|
*/
|
|
|
@KafkaListener(topics = KafkaTopicConstants.OLD_SYNC_TOPIC, groupId = "old-to-cloud-group")
|
|
@KafkaListener(topics = KafkaTopicConstants.OLD_SYNC_TOPIC, groupId = "old-to-cloud-group")
|
|
|
- //@KafkaListener(topics = "eventBus_test", groupId = "old-to-cloud-group1")
|
|
|
|
|
public void kafkaEventBusHandler(ConsumerRecord<String, String> record) {
|
|
public void kafkaEventBusHandler(ConsumerRecord<String, String> record) {
|
|
|
KafkaMessage<?> receiveMsg = JSONUtil.toBean(record.value(), KafkaMessage.class);
|
|
KafkaMessage<?> receiveMsg = JSONUtil.toBean(record.value(), KafkaMessage.class);
|
|
|
String sender = receiveMsg.getHeader().getSender();
|
|
String sender = receiveMsg.getHeader().getSender();
|