Kafka 命令行操作
# 控制台指定消费者组消费数据
在 Kafka 中,消费者可以通过设置消费者组的消费偏移量(consumer offset)来控制从哪个偏移量开始消费数据。如果消费者组还没有消费过任何数据,则可以通过指定偏移量为最早的偏移量来消费最早的数据。
在 Kafka 2.x 版本中,可以通过以下命令行指定消费者组消费最早的数据:
kafka-console-consumer.sh --bootstrap-server <broker_host>:<broker_port> --topic <topic_name> --group <consumer_group_name> --from-beginning
1
其中,--from-beginning
参数表示从最早的偏移量开始消费数据。
例如,要在消费者组 my-group
中消费主题 my-topic
的最早数据,可以使用以下命令:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --group my-group --from-beginning
1
注意,如果消费者组已经消费过一些数据,则指定 --from-beginning
参数将会从最早的偏移量开始消费,而不是从消费者组当前的偏移量开始消费。因此,应该在消费者组还没有消费过任何数据时使用该参数。
1
上次更新: 2023/11/27, 21:00:11