kafka消费消息的问题
来源：9-17 【阶段总结】Redis和Kafka在SpringBoot中的应用
nano深空彼方
2020-07-21
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注解的类,得到消息之后去处理吗?还是怎么异步处理的
写回答
1回答
-
张勤一
2020-07-21
同学你好：
第一个问题：Kafka 的消息是投递到 topic 中去的，所以，消费者消费的就是 Topic 中的 payload；
第二个问题：Kafka 只是消息队列，本身不具有异步处理的能力。我们将消息投递到 Kafka 中，消费者可以接收到消息（@KafkaListener），然后再去做处理。其实，与你的理解是基本一致的。
另外，可以看看 Kafka 的基本思想和基础理论，先学会使用 Kafka。
欢迎来 QQ 群随时交流、讨论，也非常感谢同学的支持！
10
相似问题