欢迎光临
我们一直在努力

Kafka单个Zookeeper三节点的安装步骤

前提条件:Java环境和Scala环境是可用的。

一、下载Kafka二进制包:

二、安装Zookeeper:

修改内容:

在/opt中创建zookeeper目录。

三、解压Kafka二进制包

修改配置文件server.properties:

分发二进制包到其他两台机器,至修改broker.id和host.name对应即可。

启动Zookeeper:

分别启动三台Kafka:

启动完成后,在其中一台机器上输入如下命令:

列出topic

生产者,输入数据:

消费者,消费数据,这个和producer不是在一个窗口(另一台机器):

在生产者端输入字符,会在消费者端同步出现。此处搭建完成。

未经允许不得转载:李阳博客 » Kafka单个Zookeeper三节点的安装步骤

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址