【Kafka】常用命令

创建Topic

我们提供的服务有:成都网站设计、成都网站建设、微信公众号开发、网站优化、网站认证、江苏ssl等。为数千家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务,是有科学管理、有技术的江苏网站制作公司

kafka-topics.sh --create --bootstrap-server localhost:9092 --topic abtest  --partitions 2 --replication-factor 1   

查看Topic都有哪些

kafka-topics.sh --list --zookeeper localhost:2181

生产者,将文件中的数据写入Kafka生产者

kafka-console-producer.sh --broker-list localhost:9092 --topic order_topic < abc.txt

消费者,从最开始的位移,消费Topic中的数据

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic order_topic  --from-beginning

重置Consumer Group的Offset到最新位移

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group_name_1 --reset-offsets --topic order_topic --to-latest --execute

查看消费者组Consumer Group位移

[homework@test ~]$ kafka-consumer-groups.sh --bootstrap-server  host1:9092,host2:9092  --describe --group groupname_1

TOPIC                 PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID

order                 5          20781271        20781556        285             -               -               -
order                 1          10553765        10554032        267             -               -               -
order                 2          10634508        10634808        300             -               -               -
order                 7          10375128        10375355        227             -               -               -
order                 6          10435147        10435467        320             -               -               -
order                 0          10640342        10640643        301             -               -               -
order                 3          13762141        13762478        337             -               -               -
order                 8          11176468        11176707        239             -               -               -
order                 4          10443088        10443320        232             -               -               -

标题名称:【Kafka】常用命令
当前地址:http://bzwzjz.com/article/pcdhhh.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 重庆企业网站建设 重庆电商网站建设 成都网站建设 重庆网站建设 盐亭网站设计 成都网站制作 高端网站设计 网站建设 成都网站设计 成都模版网站建设 成都网站设计 网站建设方案 网站建设改版 网站建设 企业网站设计 成都网站制作 温江网站设计 app网站建设 重庆网站建设 网站建设公司 成都网站制作 高端网站设计