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

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

Antworte allen(1)
PHPzhong

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

Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage