如果我在x个分区上创建一个主题,然后发送500位数据,编号为1到500,我希望按照发送的顺序返回数据。只有当x为1,即单个分区时,才会发生这种情况。我宁愿认为分区是寻找事物的一种效率,显然我错了?如果x大于1,即多个分区,我得到所有的数据回来,但一次值一个分区…这对我没有好处。显然,数据在每个分区内以偏移量顺序返回,但数据的顺序并不是它最初生成时的1到500。所以,简要解释一下我的想法哪里出错了,或者我应该只使用单个分区来保留我的顺序(或者在我得到一些数据后实现一堆排序,哪种类型的排序会破坏对象)。
1条答案
按热度按时间nimxete21#
我应该多研究。来自另一个线程:“kafka只提供了一个分区内消息的总顺序,而不是一个主题中不同分区之间的顺序”,因此,看起来它的单个分区仅适用于我。