这篇文章将为大家详细讲解有关卡夫卡新版常用命令有哪些,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
1/列出主题的命令为:
卡夫卡-话题。sh-动物园管理员10。211 .55 .11:2181,10.211.55.12:2181,10 .211 .55 .1333:2181/卡夫卡集团-名单。133333336
2/删除主题的命令为:
卡夫卡-话题。sh-delete-动物园管理员10。211 .55 .11:2181,10.211.55.12:2181,10 .211 .55卡夫卡集团-专题-马济辉。13:2181
3/创建主题命令如下:
卡夫卡-话题。sh-create-动物园管理员10。211 .55 .11:2181,10.211.55.12:2181,10 .211 .55卡夫卡集团-分区30-复制因素3-主题by-majihui
4/查看主题的详情包括划分和重复的分配位置
卡夫卡-话题。sh-动物园管理员10。211 .55 .11:2181,10.211.55.12:2181,10 .211 .55卡夫卡集团-描述-主题-by-majihui。55 .1233602181
5/在其中一个经纪人上创建一个生产者终端
卡夫卡-控制台-制作人。Kafka 01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092
接下来需要验证验证消息生产成功命令如下:
卡夫卡经营类。sh卡夫卡。工具。经纪人名单10。211 .55 .11:9092-话题by-majihui-time-1
6/启动终端的消费者//总结:从头开始参数如果有表示从最开始消费数据,旧的和新的数据都会被消费,而没有该参数表示只会消费新产生的数据
卡夫卡-控制台-消费者。sh-bootstrap-server kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092-topic by-majihui-从头开始
//启动一个新的消费者让他属于某个消费组新消费者-马继辉
卡夫卡-控制台-消费者。服务器10。211 .55 .1133609092-消费物业集团。id=new-consumer-majihui-consumer-property客户端。id=new-consumer-cl-topic-by-majihui
此时去执行了列出消费者就会看到:
[Hadoop @ Kafka 03-55-13 ~]$ Kafka-消费者-团体。sh-bootstrap-server kafka01-55-11:9092、kafka02-55-12:9092、kafka03-55-13:9092 - list
新消费者-马继辉
7/列出消费组//查看有哪些消费组在消费消息问题如何创建一个消费组?
卡夫卡-消费者-团体。sh-bootstrap-server Kafka 01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092 - list
卡夫卡-消费者-团体。自举服务器腾讯-kafka01-39-110:9092 -列表
8/查看某个消费组的消费进度消费详情
卡夫卡-消费群体。sh-bootstrap-server kafka01-55-11:9092、kafka02-55-12:9092、kafka03-55-13:9092-描述-组控制台-消费者-120
//这个控制台-消费者-120是上面这个查看消费组查出来的
9/查看主题某分区偏移量最大(小)值
卡夫卡经营类。sh卡夫卡。工具。getoffsetshell-topic-by-majihui-time-1-broker-list kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092-partitions 0
注:时间为-1时表示最大值,时间为-2时表示最小值
10/查看卡夫卡某分区日志具体内容指数和原木文件的具体内容查看
卡夫卡经营类。sh卡夫卡。工具。dumplogsegments-files/tmp/Kafka-logs/first topic-0/000000000000。日志-打印-数据-日志000000000000000000000。txt 0
11/卡夫卡-跑步类。sh卡夫卡。工具。dumplogsegments-files/data/Kafka/Kafka-logs/topic-by-majihui-9/0000000000000000000000000000000000000000000000000000000000000索引-打印-数据-日志000000000000000000000000索引。文本文件(textfile)
12/平衡领导者
卡夫卡-首选-复制品-选举。sh-bootstrap-server Kafka 01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092
关于"卡夫卡新版常用命令有哪些"这篇文章就分享到这里了,希望
内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/108905.html