|
blic void listenUser(ConsumerRecord<?, String> record, Acknowledgment acknowledgment) {
try {
String key = String.valueOf(record.key());
String body = record.value();
log.info("\n=====\ntopic:test，key{}，message:{}\n=====\n", key, body);
log.info("\n=====\ntopic:test，key{}，payLoadJson:{}\n=====\n", key, body);
} catch (Exception e) {
e.printStackTrace();
} finally {
//手动ack
acknowledgment.acknowledge();
}
}
}
SpringBoot Learning系列 是笔者总结整理的一个SpringBoot学习集合。可以说算是一个SpringBoot学习的大集合。欢迎Star关注。谢谢观看。
关注公众号不迷路
|