kafka 命令行操作,查看topic信息,修改消费组offset
彬 / 2021-01-28 / 1992人浏览 / 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
全部评论