Kafka常用命令行总结

以下是kafka常用命令行总结:

1.查看topic的详细信息

./kafka-topics.sh -zookeeper127.0.0.1:2181-describe -topic testKJ1

2、为topic增加副本

./kafka-reassign-partitions.sh -zookeeper127.0.0.1:2181-reassignment-json-file json/partitions-to-move.json -execute

3、创建topic

./kafka-topics.sh --create --zookeeper localhost:2181--replication-factor1--partitions1--topic testKJ1

4、为topic增加partition

./bin/kafka-topics.sh –zookeeper127.0.0.1:2181–alter –partitions20–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 --zookeeper127.0.0.1:2181--broker #brokerId# --num.retries3--retry.interval.ms60

shutdown broker

9、删除topic

./kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic testKJ1 --zookeeper127.0.0.1:2181

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏三木的博客

为虚拟机vCPU绑定物理CPU

为了提高缓存命中率,提高虚拟机性能,可以将vCPU绑定到指定的物理CPU去执行。具体设置步骤如下: 在宿主机操作系统启动时将用于虚拟机的CPU独立出来,使其上只...

3868
来自专栏木子昭的博客

解决linux端口被占用

解决端口占用问题的最快捷方式就是杀死相关进程,以杀死占用22端口的ssh为例 查看进程 如图所示,对应的进程名为sshd 进程号为 55312 输入kill ...

3996
来自专栏运维一切

私有镜像库的验证问题 原

解决方案完整的例子 https://docs.quay.io/issues/quay-mesos.html https://mesosphere.github....

722
来自专栏别先生

安装Vmware workstation虚拟机(含软件和注册码)

1:虚拟机的安装步骤,包含软件包和注册码。本博客所使用的虚拟机版本是vmware-workstation_11.1.0版本,注意不是最新版本, 软件包:http...

2167
来自专栏田飞雨的专栏

Docker 使用指南 (二):搭建本地仓库

去中央仓库下载镜像有时候非常的慢,所以 docker 本地仓库和 gitlab 类似,都是为了便于公司内部人员的使用。

5.4K0
来自专栏电光石火

Docker Settings

2163
来自专栏行者常至

Servlet运行的详细步骤

1052
来自专栏数据架构之路

时间同步-ntp服务器的搭建(docker版本)

用于构建cdm所需要的ntp服务器镜像,实现宿主机和ntpserver同步,ntpserver于ntpclient的同步

3345
来自专栏运维小白

6.3 bzip2压缩工具

bzip2目录概要 bzip2 1.txt 或 bzip2 -z 1.txt 压缩文件 bzip2 -d 1.txt.bz2 或 ...

1886
来自专栏CodeSheep的技术分享

Docker Swarm 集群初探

25014

扫码关注云+社区

领取腾讯云代金券