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