【kafka】Topic管理
发表于：2024-11-24 作者：热门IT资讯网编辑
编辑最后更新 2024年11月24日，1.查看已经创建的Topiccd /usr/local/kafka./bin/kafka-topics.sh --list --zookeeper 10.1.44.186:2181,10.1.44.1
1.查看已经创建的Topic
cd /usr/local/kafka./bin/kafka-topics.sh --list --zookeeper 10.1.44.186:2181,10.1.44.187:2181,10.1.44.188:2181186 187 188------------------ ------------------ ------------------__consumer_offsets __consumer_offsets __consumer_offsetsconnect-test connect-test connect-testtest0320 test0320 test0320
2.创建topic
cd /usr/local/kafka./bin/kafka-topics.sh --create --zookeeper 10.1.44.186:2181,10.1.44.187:2181,10.1.44.188:2181 --partitions 3 --replication-factor 2 --topic test0326# 创建后各broker上的物理目录186 187 188---------- ---------- ----------test0326-1 test0326-1 test0326-1test0326-2 test0326-2 test0326-2
3.查看指定topic中Leader的信息
cd /usr/local/kafka./bin/kafka-topics.sh --describe --zookeeper 10.1.44.186:2181,10.1.44.187:2181,10.1.44.188:2181 --topic test0326Topic: test0326 PartitionCount:3 ReplicationFactor:2 Configs:Topic: test0326 Partition: 0 Leader: 0 Replicas: 0,2 Isr: 0,2Topic: test0326 Partition: 1 Leader: 1 Replicas: 1,0 Isr: 1,0Topic: test0326 Partition: 2 Leader: 2 Replicas: 2,1 Isr: 2,1
4.查看consumer组内消费的offset
(1) 使用生产者生成一次
(2) 使用test组消费一次
(3) test组当前的消费偏移
offset = 828 , partition=1, key = 4, value = hh老高4
offset = 829 , partition=1, key = 6, value = hh老高6
offset = 1095, partition=0, key = 1, value = hh老高1
offset = 1096, partition=0, key = 5, value = hh老高5
offset = 1097, partition=0, key = 7, value = hh老高7
offset = 1098, partition=0, key = 8, value = hh老高8
offset = 568 , partition=2, key = 0, value = hh老高0
offset = 569 , partition=2, key = 2, value = hh老高2
offset = 570 , partition=2, key = 3, value = hh老高3
offset = 571 , partition=2, key = 9, value = hh老高9
cd /usr/local/kafka./bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 10.1.44.186:2181,10.1.44.187:2181,10.1.44.188:2181 --group test --topic test0320# [2018-03-26 11:06:17,939] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)Group Topic Pid Offset logSize Lag Ownertest test0320 0 1099 1099 0 nonetest test0320 1 830 830 0 nonetest test0320 2 572 572 0 none
5.kafka-consumer-offset-checker.sh脚本
# bin/kafka-consumer-offset-checker.shOption Description ------ ----------- --broker-info 打印broker信息--group 消费着组--help 帮助信息--retry.backoff.ms? Retry back-off to use for failed offset queries. (default: 3000)--socket.timeout.ms ? Socket timeout to use when querying for offsets. (default: 6000)--topic 以逗号分隔的消费者主题列表（如果不存在的话，所有主题）--zookeeper zookeeper地址cd /usr/local/kafkabin/kafka-consumer-offset-checker.sh --zookeeper 10.1.44.186:2181,10.1.44.187:2181,10.1.44.188:2181 --topic test0320 --group test --broker-info[2018-03-26 11:24:52,014] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)Group Topic Pid Offset logSize Lag Ownertest test0320 0 1115 1115 0 nonetest test0320 1 838 838 0 nonetest test0320 2 588 588 0 noneBROKER INFO2 -> 10.1.44.188:90921 -> 10.1.44.187:90920 -> 10.1.44.186:9092