Kafka的consumer如何根据offset来确定读取哪个patition呢?

刚接触kafka研究其原理,了解到在同一个partition内部消息是保证有序的

但是我用一个consumer去读多个partition的topic的时候,利用的只是一个offset。那kafka是如何利用这个offset去确定应该读哪个partition呢?

阅读 6.9k
1 个回答

内部储存单元是map
key是TopicPartition, 里面记录了topic和partition
value是offset
所以不存在只存在offset但是不知道partition的情况

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题