作者:彬
链接:http://www.java78.com/article/70.html
声明:请尊重原作者的劳动,如需转载请注明出处
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 | - |
将消费组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
全部评论