Kafka 运行命令
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Kafka 运行命令相关的知识，希望对你有一定的参考价值。
参考技术A 一、启动ZooKeeper打开一个新终端并键入以下命令
二、要启动Kafka Broker，请键入以下命令
启动Kafka Broker后，在ZooKeeper终端上键入命令 jps ，您将看到以下响应
现在你可以看到两个守护进程运行在终端上，QuorumPeerMain是ZooKeeper守护进程，另一个是Kafka守护进程。
三、创建Kafka主题
四、主题列表
要获取Kafka服务器中的主题列表，可以使用以下命令
输出
五、启动生产者以发送消息
六、启动消费者以接收消息
七、单节点多代理配置
创建多个Kafka Brokers，我们在配置/ server.properties中已有一个Kafka代理实例。 现在我们需要多个代理实例，因此将现有的server.prop-erties文件复制到两个新的配置文件中，并将其重命名为server-one.properties和server-two.properties。 然后编辑这两个新文件并分配以下更改
config / server-one.properties
创建主题
让我们为此主题将复制因子值指定为三个，因为我们有三个不同的代理运行。 如果您有两个代理，那么分配的副本值将是两个。
Describe 命令用于检查哪个代理正在侦听当前创建的主题
输出
八、修改主题
以上是关于Kafka 运行命令的主要内容，如果未能解决你的问题，请参考以下文章