kafka 命令行操作,查看topic信息，修改消费组offset
2021-01-28 20:16
152
0
查看topic信息
bin/kafka-topics.sh --zookeeper zookeeper:2181 --list
TEST1
TEST2
__consumer_offsets
查看消费组
0.8版本及以下的的kafka 使用如下命令查看有那些消费者group
bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --list
0.9版本及以上的kafka建议使用如下命令查看有那些消费者group，当然也可使用上一条命令消费
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
test1
test2
查看某个消费者消费情况
0.8版本及以下的的kafka 使用如下命令查看名为testgroup 的消费组的消费情况
bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --group testgroup --describe
0.9版本及以上的的kafka 使用如下命令查看名为testgroup 的消费组的消费情况
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group portal --describe
| GROUP | TOPIC | PARTITION | CURRENT-OFFSET | LOG-END-OFFSET LAG | CONSUMER-ID HOST | CLIENT-ID |
|---|---|---|---|---|---|---|
| test1 | TEST1 | 0 | 34794 | 34872 | 78 |
| GROUP | TOPIC | PARTITION | CURRENT-OFFSET | LOG-END-OFFSET LAG | CONSUMER-ID HOST | CLIENT-ID |
|---|---|---|---|---|---|---|
| test2 | TEST2 | 0 | 47687 | 47695 | 8 | - |
修改kafka消费组的位偏移量
将消费组offset设置到最后30分钟
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test2--reset-offsets --all-topics --by-duration PT0H30M0S
将消费组offset设置到最新
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test1 --reset-offsets --all-topics --to-latest --execute
全部评论