Kafka有新旧Consumer Api之分,旧的ConsumerApi提交的组信息及offset是存放在zookeeper中的,
而由于zookeeper并不适合频繁的大批量写入操作,所以在新的ConsumerApi的设计中,
新建了一个__consumer_offsets
Topic用于存放新ConsumerApi提交的组信息及offset。
所以现在有了新旧Api之分,旧的提交上来的还是存在zookeeper中。
kafka提供的工具脚本中和Consumer相碰的都有个选项--new-consumer
,
用以区分新旧Api。