kafka会提交offset到 __consumer_offsets 这个topic上,但是没想明白这个topic是怎么被利用上的。
主要问题是:
- kafka新启动的cosumer是怎么获取到上次消费的offset的?是直接去消费 __consumer_offsets 这个topic获取offset么?这样那不是需要过滤掉很多消息?
- 新建立的broker在分配了partition之后,是怎么知道自己当前负责的partition的offset的?
kafka会提交offset到 __consumer_offsets 这个topic上,但是没想明白这个topic是怎么被利用上的。
主要问题是: