java - Kafka的consumer如何根据offset来确定读取哪个patition呢?
天蓬老师
天蓬老师 2017-04-18 10:41:48
0
1
472
天蓬老师
天蓬老师

欢迎选择我的课程,让我们一起见证您的进步~~

reply all(1)
PHPzhong

The internal storage unit is map
key is TopicPartition, which records topic and partition
value is offset
So there is no situation where only offset exists but the partition is not known

Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template