kafka客户端脚本windows版
发布日期:2021-06-28 18:42:11
浏览次数:2
分类:技术文章
本文共 4813 字,大约阅读时间需要 16 分钟。
以下脚本除集群启动,均视为kafka客户端,因此放在windows上运行即可,不必放在linux上,即用windows上的kafka客户端,访问linux上的kafka服务器
1、第一版(不建议使用)
1.1、集群启动
@echo offecho %date% %time%,开始启动kafka集群!start /b /d "server1/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server1/config/server.properties>> server1.logstart /b /d "server2/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server2/config/server.properties>> server2.logstart /b /d "server3/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server3/config/server.properties>> server3.log
1.2、创建主题
@echo offecho 请输入要创建的主题名:set /p topicName=:startecho 请输入分区数目:set /p partitions=echo 正在创建主题%topicName%...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --create --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster --replication-factor 3 --partitions %partitions% --topic %topicName%echo 继续创建主题请输入主题名:set /p topicName=goto startpause > nul
1.3、查看主题
@echo offecho 正在查询主题列表...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --list --zookeeper localhost:2181/KafkaClusterecho 请输入主题名称,若直接回车则视为查看所有主题详情:set /p topicName=echo 正在查询...if defined topicName (start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster --topic %topicName%) else (start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster)pause > nul
1.4、查看消费组
@echo offecho 正在查询消费者组列表...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --listecho 请输入消费者组:set /p group=:startecho 正在查询消费者组详情...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --describe --group %group%echo 继续查看其他消费者组详情,请输入消费者组:set /p group=goto start
1.5、生产者
@echo offecho 请输入生产者发布的主题:set /p topicName=./server1/bin/windows/kafka-console-producer.bat --broker-list localhost:9092,localhost:9093,localhost:9094 --topic %topicName% --producer.config ./server1/config/producer.properties
1.6、消费者
@echo offecho 请输入消费者订阅的主题:set /p topicName=echo 请输入groupId:set /p groupId=echo 请输入clientId:set /p clientId=./server1/bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --topic %topicName% --from-beginning --consumer-property group.id=%groupId% client.id=%clientId%
2、第二版
2.1、创建主题
@echo offecho 请输入zookeeper.connect(如[localhost:2181]):set /p zkconn=echo 请输入要创建的主题名:set /p topicName=echo 请输入分区数目:set /p partitions=echo 请输入副本数目:set /p factor=echo 正在创建主题%topicName%...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --create --zookeeper %zkconn% --replication-factor %factor% --partitions %partitions% --topic %topicName%pause > nul
2.2、查看主题
@echo offecho 请输入zookeeper.connect(如[localhost:2181]):set /p zkconn=echo 正在查询主题列表...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --list --zookeeper %zkconn%echo 请输入主题名称,若直接回车则视为查看所有主题详情:set /p topicName=echo 正在查询...if defined topicName (start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper %zkconn% --topic %topicName%) else (start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper %zkconn%)pause > nul
2.3、 查看消费者群组
@echo offecho 请输入bootstrap-server(如[localhost:9092]):set /p bs=echo 正在查询消费者组列表...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server %bs% --listecho 请输入消费者组:set /p group=:startecho 正在查询消费者组详情...start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server %bs% --describe --group %group%echo 继续查看其他消费者组详情,请输入消费者组:set /p group=goto start
2.4、生产者
@echo offecho 请输入broker-list(如[localhost:9092]):set /p brokerList=echo 请输入生产者发布的主题:set /p topicName=echo 生产者使用配置文件:./server1/config/producer.properties./server1/bin/windows/kafka-console-producer.bat --broker-list %brokerList% --topic %topicName% --producer.config ./server1/config/producer.properties
2.5、消费者
@echo offecho 请输入bootstrap-server(如[localhost:9092]):set /p bs=echo 请输入消费者订阅的主题:set /p topicName=echo 消费者使用配置文件:./server1/config/consumer.properties./server1/bin/windows/kafka-console-consumer.bat --bootstrap-server %bs% --topic %topicName% --from-beginning --consumer.config ./server1/config/consumer.properties
转载地址:https://blog.csdn.net/xl_1803/article/details/103423610 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
路过,博主的博客真漂亮。。
[***.116.15.85]2024年04月15日 17时09分22秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
中台的末路
2019-04-29
万字长文揭秘:阿里如何实现海量数据实时分析?
2019-04-29
大数据的过去、现在和未来:万字长文解读《大数据四十二条》
2019-04-29
阿里巴巴高级算法专家威视:组建技术团队的一些思考
2019-04-29
美团点评基于 Flink 的实时数仓平台实践
2019-04-29
网易数据中台建设实践
2019-04-29
大数据架构如何做到流批一体?
2019-04-29
如何才能成为顶级的数据分析师?
2019-04-29
数据中台应该包含什么?
2019-04-29
不做中台当然会死!
2019-04-29
春节荐书 | 2019年我读过的十本好书
2019-04-29
在阿里做了五年技术主管,我有话想说
2019-04-29
写给机器学习从业者的12条宝贵建议
2019-04-29
深入浅出大数据存储架构,如何设计才能满足需求?
2019-04-29
阿里资深技术专家胡月军:大数据十年,我看到的技术变化和趋势
2019-04-29
业务为王,这两年我们采用的那些数据产品和技术引擎
2019-04-29
阿里资深技术专家的10年感悟
2019-04-29
好吧,你赢了!数据从业者权威嘲讽指南!
2019-04-29
超级菜鸟如何入门数据分析?
2019-04-29
产品的天机和成败:我的实践史与俞军的方法论
2019-04-29