刚接触kafka研究其原理,了解到在同一个partition内部消息是保证有序的
但是我用一个consumer去读多个partition的topic的时候,利用的只是一个offset。那kafka是如何利用这个offset去确定应该读哪个partition呢?
刚接触kafka研究其原理,了解到在同一个partition内部消息是保证有序的
但是我用一个consumer去读多个partition的topic的时候,利用的只是一个offset。那kafka是如何利用这个offset去确定应该读哪个partition呢?
15 回答8.2k 阅读
8 回答5.9k 阅读
1 回答4.1k 阅读✓ 已解决
3 回答2.2k 阅读✓ 已解决
2 回答3.1k 阅读
2 回答3.8k 阅读
1 回答2.2k 阅读✓ 已解决
内部储存单元是map
key是TopicPartition, 里面记录了topic和partition
value是offset
所以不存在只存在offset但是不知道partition的情况