Kafka集群相关指令

启动zk集群
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &启动kafka集群
bin/kafka-server-start.sh config/server.properties &创建topic
bin/kafka-topics.sh --create --zookeeper 192.1.x.x:2181,192.1.x.1:2181,192.1.x.3:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic查看topic信息
bin/kafka-topics.sh --describe --zookeeper 192.1.x.x:2181,192.1.x.1:2181,192.1.x.3:2181 --topic my-replicated-topic生产者生产消息
bin/kafka-console-producer.sh --broker-list 192.1.x.x:9092,192.1.x.1:9093,192.1.x.3:9092 --topic my-replicated-topic从头开始消费消息
bin/kafka-console-consumer.sh --bootstrap-server 192.168.x.a:9092 --zookeeper 192.1.x.x:2181,192.1.x.1:2181,192.1.x.3:2181 --from-beginning --topic my-replicated-topic

重启kafka
sh kafka-server-start.sh ../config/server.properties &
sh kafka-server-stop.sh ../config/server.properties &列出所有topic
./kafka-topics.sh --list  --zookeeper 172.16.b.a:2181查看指定topic的数据数量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.10.x:9092 --topic topic_name --time -1zk删除topic
rmr /brokers/topics/topic_name删除指定topic./kafka-topics.sh  --zookeeper 192.168.10.z:2181 --delete --topic topic_name导出指定topic数据
./bin/kafka-console-consumer.sh --bootstrap-server 172.16.11.a:9092 --topic topic_name --from-beginning > topic_name.json创建topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic topic_name启动生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic test0919启动消费
./kafka-console-consumer.sh --zookeeper 192.168.10.zx:2181 --topic topic_name --from-beginning查看消费者ID
./kafka-consumer-groups.sh --zookeeper 192.168.10.a:2181 --list查看指定消费者组情况
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.a:9092,192.168.100.b:9092,192.168.100.c:9092 --group groupId_name --describe --new-consumer

Kafka集群相关指令相关推荐

滴滴Logi-KafkaManager开源之路：一站式Kafka集群指标监控与运维管控平台
导读从2019年4月份计划开源到2021月1月14号完成开源,历时22个月终于修成正果,一路走来实属不易,没有前端.设计.产品,我们找实习生.合作方.外部资源支持,滴滴Kafka服务团队人员也几经调 ...
Kafka（二）- Kafka集群部署
文章目录一.安装部署 1. 集群规划 2. 虚拟机前置准备工作 (1)配置IP (2)修改主机名称和hosts文件 (3)关闭防火墙,关闭防火墙开机自启 (4)克隆虚拟机 3. 集群部署 (1)解压 ...
Kafka 集群搭建（含 ZK 模式和 Kraft 模式）
前言环境介绍虚拟机软件:VirtualBox Linux 发行版本:Ubuntu 20.04.4 虚拟机核心数:1 core 虚拟机内存:2 GB JDK 版本:1.8.0_202 ZK 版本:3 ...
docker-compose快速搭建kafka集群
文章目录前言 docker-compose快速搭建kafka集群(较详细) docker-compose快速搭建Zookeeper集群+kafka集群参考资料前言当前是在学习kafka3.0的 ...
kafka的简单介绍以及docker-compose部署单主机Kafka集群
Kafka简单介绍 Kafka是由Apache软件基金会开发的一个分布式.分区的.多副本的.多订阅者的开源流处理平台,由Scala和Java编写.Kafka是一种高吞吐量的分布式发布订阅消息系统,它可 ...
大数据 -- zookeeper和kafka集群环境搭建
一运行环境从阿里云申请三台云服务器,这里我使用了两个不同的阿里云账号去申请云服务器.我们配置三台主机名分别为zy1,zy2,zy3. 我们通过阿里云可以获取主机的公网ip地址,如下: 通过secu ...
几种常见的Kafka集群监控工具「送书」
本文选自电子工业出版社的新书<kafka进阶>,推荐一下. 送书规则:文末留言,精选精彩留言,对留言点赞最多的4位包邮送书一本~ 截止时间:2022.06.20 8:00 一个功能健全的 ...
Kafka集群间同步数据方案-Flume
Apache Flume 是一个分布式.高可靠.高可用的用来收集.聚合.转移不同来源的大量日志数据到中央数据仓库的工具. 系统要求 Java运行环境 - Java 1.8或更高版本体系结构 Even ...
Hyperledger Fabric 1.4 Kafka集群部署教程
Hyperledger Fabric 1.4 Kafka集群部署教程作者:区块链教程时间:2019/12/08 10:36 标签:Docker ComposeDockerYMLHyperledge ...

Kafka集群相关指令

Kafka集群相关指令相关推荐

最新文章

热门文章