【kafka】Topic管理-创新互联
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:2181 186 187 188 ------------------ ------------------ ------------------ __consumer_offsets __consumer_offsets __consumer_offsets connect-test connect-test connect-test test0320 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-1 test0326-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 test0326 Topic: test0326 PartitionCount:3 ReplicationFactor:2 Configs: Topic: test0326 Partition: 0 Leader: 0 Replicas: 0,2 Isr: 0,2 Topic: test0326 Partition: 1 Leader: 1 Replicas: 1,0 Isr: 1,0 Topic: 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 Owner test test0320 0 1099 1099 0 none test test0320 1 830 830 0 none test test0320 2 572 572 0 none
5.kafka-consumer-offset-checker.sh脚本
# bin/kafka-consumer-offset-checker.sh Option Description ------ ----------- --broker-info 打印broker信息 --group 消费着组 --help 帮助信息 --retry.backoff.ms <Integer> ? Retry back-off to use for failed offset queries. (default: 3000) --socket.timeout.ms <Integer> ? Socket timeout to use when querying for offsets. (default: 6000) --topic 以逗号分隔的消费者主题列表（如果不存在的话，所有主题） --zookeeper zookeeper地址 cd /usr/local/kafka bin/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 Owner test test0320 0 1115 1115 0 none test test0320 1 838 838 0 none test test0320 2 588 588 0 none BROKER INFO 2 -> 10.1.44.188:9092 1 -> 10.1.44.187:9092 0 -> 10.1.44.186:9092
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
分享名称：【kafka】Topic管理-创新互联
网址分享：https://www.cdcxhl.com/article32/didepc.html
成都网站建设公司_创新互联，为您提供移动网站建设、建站公司、网站建设、手机网站建设、网站设计公司、虚拟主机
声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联
- 为什么就要做响应式网站 和手机网站有什么不同 2016-09-06
- RWD响应式网站的优点有哪些？ 2023-02-22
- 为什么要做响应式网站?-东莞网站建设 2022-05-10
- 响应式网站制作在移动互联网时代企业更应考虑 2021-10-01
- 碑林营销网站设计公司：响应式网站设计有哪些需要引起重视 2023-02-16
- 响应式网站到底具备哪些优势？ 2023-03-05
- 重庆响应式网站建设的趋势 2021-01-17
- 响应式网站建设：为什么它对您来说很重要 2016-09-15
- 讲解目前大多企业选择响应式网站建设的原因 2023-02-23
- 成都网站制作公司：企业如何高效搭建响应式网站 2022-12-25
- 响应式网站开发有哪些优势不和足？ 2022-07-08
- 响应式网站建设和PC手机网站都有哪些区别？ 2023-01-02