部署Kafka集群

部署ZooKeeper集群成功后，就可以部署Kafka集群了（部署ZooKeeper集群见上一篇文章）。这里笔者部署一个3节点的Kafka集群。

1. 准备环境

（1）同样准备3台机器，安装OpenJDK11，用于部署Kafka集群。

（2）下载kafka_2.13-3.0.0.tgz，解压并进入kafka_2.13-3.0.0。

2. 修改配置

修改Kafka默认的配置文件config/server.properties：

 broker.id=0zookeeper.connect=zk1:2181,zk2:2181,zk3:2181

zookeeper.connect：ZooKeeper连接地址。broker.id：Kafka的服务Id，必须为整数，不同节点的Kafka需要配置不同的broker.id。这里笔者为3个Kafka节点配置了服务Id：0、1、2。

Kafka中还有很多配置，后面的章节中会对其进行介绍，这里只介绍必须修改的配置。

3. 启动服务

（1）在3台机器上使用以下命令启动Kafka服务。

 $ ./bin/kafka-server-start.sh config/server.properties

如果需要后台启动Kafka服务，则可以使用以下命令：

 $ ./bin/kafka-server-start.sh -daemon config/server.properties

Kafka日志会输出到logs/kafkaServer.out文件中。

（2）3个集群的Kafka服务都启动后，可以使用以下命令创建一个主题。

 $ ./bin/kafka-topics.sh  --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic hello-topicCreated topic hello-topic.

如果能成功创建主题，则说明Kafka集群部署成功。

内容摘自《深入理解Kafka与Pulsar》，本书详细介绍了Kafka与Pulsar的使用方式，并深入分析了它们的实现机制。通过阅读本书，读者可以快速入门和使用Kafka与Pulsar，并深入理解它们的实现原理。

适读人群 ：Kafka、Pulsar的专业技术人员。 大数据相关应用的开发者、运维者和爱好者。