(March 24, 2015) 这时候就用到了第5步获取的group.id(本例中是console-consumer-46965)。Kafka会使用下面公式计算该group位移保存在__consumer… kafka-console-consumer --topic example-topic --bootstrap-server broker:9092 --from-beginning. Step 1: Discover and connect to the offset manager for a consumer group by issuing a consumer … When you’re working from the terminal, you can use kafka-console-consumer without group.id, a new group.id is generated using: console-consumer … kafka-console-consumer.sh --bootstrap-server --topic --offset --partition Consume from kafka topic and specify consumer … Offset … Offset Management¶. Overview of consumer offset management in Kafka presented at Kafka meetup @ LinkedIn. 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.. x The simplest command syntax is. 7. The official Kafka documentation describes how the feature works and how to migrate offsets from ZooKeeper to Kafka. ... To get started with the consumer, add the kafka … Topic _consumer_offsets, which is the default and is already available in Kafka Broker store, offsets information in Broker. From Command-Line. For example, in the figure below, the consumer’s position is at offset 6 and its last committed offset is at offset 1. kafka-consumer-groups.sh \ --bootstrap-server localhost:29092 \ --describe --group