以下是kafka常用命令行总结:
1.查看topic的详细信息
./kafka-topics.sh -zookeeper 127.0.0.1:2181 -describe -topic testKJ1
2、为topic增加副本
./kafka-reassign-partitions.sh -zookeeper 127.0.0.1:2181 -reassignment-json-file json/partitions-to-move.json -execute
3、创建topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testKJ1
4、为topic增加partition
./bin/kafka-topics.sh –zookeeper 127.0.0.1:2181 –alter –partitions 20 –topic testKJ1
5、kafka生产者客户端命令
./kafka-console-producer.sh --broker-list localhost:9092 --topic testKJ1
6、kafka消费者客户端命令
./kafka-console-consumer.sh -zookeeper localhost:2181 --from-beginning --topic testKJ1
7、kafka服务启动
./kafka-server-start.sh -daemon ../config/server.properties
8、下线broker
./kafka-run-class.sh kafka.admin.ShutdownBroker --zookeeper 127.0.0.1:2181 --broker #brokerId# --num.retries 3 --retry.interval.ms 60
shutdown broker
9、删除topic
./kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic testKJ1 --zookeeper 127.0.0.1:2181
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic testKJ1
10、查看consumer组内消费的offset
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test --topic testKJ1
分享到:
相关推荐
以下是kafka常用命令行总结: 1.查看topic的详细信息 ./kafka-topics.sh -zookeeper 127.0.0.1:2181 -describe -topic testKJ1 2、为topic增加副本 ./kafka-reassign-partitions.sh -zookeeper 127.0.0.1:2181 -...
kafka常用的基本命令行
与Apache Kafka交互的命令行界面 | 特征 bash,zsh,fish shell的命令自动完成,包括例如主题或消费者组的动态完成。 支持Avro模式 不同环境的配置 直接访问kubernetes集群中的kafka集群 安装 您可以安装预编译的...
Kafka常用的命令操作,包括服务的启动管理,主题、分区、生产者、消费者、配置、镜像操作,最后加了开启kafka jmx监控的一种方式。
资源内容: 1,Kafka的安装与服务启停命令; 2,Kafka的Topic的操作指令命令; 3,消息的生产与消费的命令; 4,分组及其它命令; 5,相关问题及解决办法;
总结了下kafka常用的命令
kafka的常用命令集锦
个人学习kafka总结,私人使用,个人学习kafka总结,私人使用,个人学习kafka总结,私人使用
kafka常用命令
Kafka基础学习总结,从小白学习,基础开始到精通
01_尚硅谷_Kafka_课程介绍.avi 02_尚硅谷_Kafka_消息队列介绍.avi 03_尚硅谷_Kafka_概念.avi 04_尚硅谷_Kafka_架构.avi 05_尚硅谷_Kafka_集群搭建&启动.avi 06_尚硅谷_Kafka_命令行操作.avi 07_尚硅谷_Kafka_工作...
kafka3.2常用命令
kafka对主题、分区、副本的一些常用命令。
kafka的概念和一些基础的机制,如基础概念,分组策略,数据的完全生产,负载均衡等
自己写的一些kafka常用功能点
日记月累,收录kafka各种命令,会持续更新。 在0.9.0.0之后的Kafka,出现了几个新变动,一个是在Server端增加了GroupCoordinator这个角色,另一个较大的变动是将topic的offset 信息由之前存储在zookeeper上改为...
Raccoon 是一个用 Go 编写的 Apache Kafka 命令行搜索工具。 该工具使用户能够通过提供搜索查询来搜索和 grep Kafka 主题中的特定消息。 此外,该工具还允许用户跟踪 Kafka 主题并根据提供的搜索查询过滤消息。 完成...
消费kafka某时间段消息用于分析问题,生产环境海量数据,用kafka-console-consumer.sh只能消费全量,文件巨大,无法grep。 代码来源于博主:BillowX_ ,感谢分享 原贴地址:...