该组的偏移信息之前存储在zookeeper中.现在,在Kafka Cluster(0.10.x)中,偏移信息存储在名称为的主题中__consumer_offsets.
__consumer_offsets
但是我怎么能得到我指定的组的偏移信息呢?
apache-kafka
apache-kafka ×1