In this first scenario, we will see how to manage offsets from command-line so it will give us an idea of how to implement it in our application.. ... To get started with the consumer, add the kafka … 这时候就用到了第5步获取的group.id(本例中是console-consumer-46965)。Kafka会使用下面公式计算该group位移保存在__consumer… This wiki provides sample code that shows how to use the new Kafka-based offset storage mechanism. kafka-console-consumer.sh --bootstrap-server --topic --offset --partition Consume from kafka topic and specify consumer … When a partition gets reassigned to another consumer in the group, the initial position is set to the last committed offset. From Command-Line. The offset is the position of a Kafka - Consumer in a Kafka - Topic An offset is not the Kafka - Key but an automatic Kafka - (Record|Message) position id For versions less than 0.9 Apache Kafka - Zookeeper was used for managing the offsets of the consumer group. The simplest command syntax is. 计算指定consumer group在__consumer_offsets topic中分区信息. kafka-consumer-groups.sh \ --bootstrap-server localhost:29092 \ --describe --group