什么是spring kafkalistener的阅读策略,有几个主题?

sgtfey8w  于 2021-08-25  发布在  Java
关注(0)|答案(1)|浏览(502)

Kafka如何处理几个主题?

@KafkaListener(topics = {"topic1" , "topic2"}, groupId = "groupid")

例如:
“topic1”在单个分区上有“topic1_message1”、“topic1_message2”实体
“topic2”在单个分区上有“topic2_message1”、“topic2_message2”实体
阅读顺序是什么?
“主题1_消息1”、“主题1_消息2”、“主题2_消息1”、“主题2_消息2”
“主题1_消息1”、“主题2_消息1”、“主题1_消息2”、“主题2_消息2”
或者服务器将示例化同时读取这两个主题的两个线程?

ehxuflar

ehxuflar1#

这两个都是事实。它是随机的
“主题1_消息1”、“主题1_消息2”、“主题2_消息1”、“主题2_消息2”
“主题1_消息1”、“主题2_消息1”、“主题1_消息2”、“主题2_消息2”
因为它们位于单个分区上,所以您应该知道一件事;
“主题1\u消息1”位于“主题1\u消息2”之前
“主题2_消息1”位于“主题2_消息2”之前

相关问题