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

全部评论