Kafka命令及相关参数解释

由于kafka是去中心化的架构，，所以需要在每台节点上启动kafka，且依赖于zookeeper，需要先启动zookeeper

启动kafka:

kafka-server-start.sh -daemon /opt/modules/kafka_2.12-2.4.0/config/server.properties

-daemon是后台启动的意思

创建一个新的topic：

kafka-topics.sh --create --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --replication-factor 3 --partitions 3 --topic topicname

–replication-factor 副本的数量

–partitions 分区的数量

查看所有的Topic：

kafka-topics.sh --list  --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181

启动一个控制台生产者：

kafka-console-producer.sh --topic topicname --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092

–broker-list broker的列表，端口号是默认的，如果你修改了，需要指定为你修改过的端口

启动控制台消费者：

kafka-console-consumer.sh --bootstrap-server hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic topicname

指定消费的topic的名字

查看一个topic的描述:

kafka-topics.sh  --describe --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --topic topicname

写的不好还请在评论区指出，感谢您的阅读。

Kafka命令及相关参数解释相关推荐

oracle dg fal client,创建物理备库（DG）及相关参数解释
此文默认你会使用dbca创建数据库,并了解数据库的相关目录结构及spfile.file.密码文件等位置. 1.创建主数据库使用一dbca创建数据主库,sid为dg1,数据库名为dg,并且设置db_u ...
mysql 更新统计信息_MySQL5.7统计信息更新的相关参数解释和测试
MySQL版本:5.7.21 统计信息相关参数如下: mysql> show global variables like '%stats%'; +------------------------ ...
jstack命令相关参数解释（tid,nid,prio,os_prio）
tid: java内的线程id nid: 操作系统级别线程的线程id prio: java内定义的线程的优先级 os_prio:操作系统级别的优先级
【云原生】查看 Docker 容器启动命令和相关参数
安装Python3 Linux 一般都默认安装了 Python 2,而 Python2 就附带了 pip 命令,但 2 版本的 pip 经常在安装包的时候出错,所以建议安装 Python3.使用如下命 ...
mysql命令行各个参数解释
mysql -u root -p 等这些常用的参数外,你知道多少?来测试一下吧一,mysql命令行参数查看复制打印? Usage: mysql [OPTIONS] [database] //命令方 ...
mysql慢查询日志轮转_MySQL slow log相关参数解释
slow_query_log=1 #是否启用慢查询日志,1为启用,0为禁用 slow_query_log_file=slow.log #指定慢查询日志文件的路径和名字,可使用绝 ...
【Kafka】Kafka生产者producer相关参数详解batch.size linger.ms 等参数
1.概述生产环境中使用Kafka,参数调优非常重要,而Kafka参数众多,我们的java的Configuration代码中,经常设置的参数如下: Properties props = new Pro ...
服务器中使用Top命令后，参数解释
一.问题描述 top命令是最方便可用的服务器监控命令,可以看出服务器的当前负载量,CPU占用率,内存占用率等重要信息. 展示两种情景: 情景一:top命令即可:要是想要退出就按q即可情景二:在情 ...
JVM内存模型、相关参数设置与命令查看
JVM内存模型.相关参数设置与命令查看 JVM内存模型,你看这一篇就够了 - 知乎 (zhihu.com) Java虚拟机-Java8内存模型JVM(整理版) - 牧梦者 - 博客园 (cnblogs ...

Kafka命令及相关参数解释

Kafka命令及相关参数解释

启动kafka:

创建一个新的topic：

查看所有的Topic：

启动一个控制台生产者：

启动控制台消费者：

查看一个topic的描述:

Kafka命令及相关参数解释相关推荐

最新文章

热门文章