我正在用java编写一个简单的kafka使用者,它被配置为读取多个主题。现在,让我们假设两个主题(主题1和主题2)和两个主题的单个分区。
Kafka消费者阅读主题1和主题2的顺序是什么。如果两个主题都已经发布了100条消息。
假设topic1具有以下按时间顺序排列的消息(a1、a2、a3………a100)。
假设topic2有以下按时间顺序排列的消息(b1、b2、b3、…b100)。
从主题收到的信息的顺序是什么,
使用者首先读取topic1中的所有消息,然后读取topic2?
消费者按时间顺序阅读来自两个主题的信息?
我看了Kafka的文件,找不到这方面的参考资料。非常感谢您的帮助。
1条答案
按热度按时间h43kikqp1#
使用者将在每次轮询中提取多少数据取决于使用者配置(轮询记录、轮询间隔、获取最大字节数、最大分区大小等),因此不能保证消息在主题分区之间的顺序,因为顺序仅在主题分区内维护