kafka消费消息的问题

Question

1 @KafkaListener(topics = {Constant.TOPIC}, groupId = “imooc-coupon-1”)’'
加上这个注解
是指怎样消费服务器上的消息,消费topic里面的消息吗?

2 // 发送到 kafka 中做异步处理
kafkaTemplate.send(
Constant.TOPIC,
JSON.toJSONString(new CouponKafkaMessage(
CouponStatus.EXPIRED.getCode(),
classify.getExpired().stream()
.map(Coupon::getId)
.collect(Collectors.toList())
))
);
这种发送到kafka上的消息做异步处理
是等@KafkaListener注解的类,得到消息之后去处理吗?还是怎么异步处理的

Answer 1

张勤一 2020-07-21 09:54:39

同学你好：

    第一个问题：Kafka 的消息是投递到 topic 中去的，所以，消费者消费的就是 Topic 中的 payload；

    第二个问题：Kafka 只是消息队列，本身不具有异步处理的能力。我们将消息投递到 Kafka 中，消费者可以接收到消息（@KafkaListener），然后再去做处理。其实，与你的理解是基本一致的。

    另外，可以看看 Kafka 的基本思想和基础理论，先学会使用 Kafka。

    欢迎来 QQ 群随时交流、讨论，也非常感谢同学的支持！