Kafka集群的搭建非常简单,需要先安装JDK。
一、从官网下载Kafka
目前的最新稳定版是2.3.0,下载kafka_2.12-2.3.0.tgz然后直接解压即可:
二、修改配置文件server.properties
修改config目录下的server.properties,其中需要重点关注的是:
1)broker.id。The id of the broker. This must be set to a unique integer for each broker.
2)log.dirs。A comma separated list of directories under which to store log files.
3)zookeeper.connect。Zookeeper connection string. You can also append an optional chroot string to the urls to specify the root directory for all kafka znodes.
4)listeners。The address the socket server listens on.
5)advertised.listeners。
其他参数单独讨论。
三、启动Kafka服务
在bin目录下有数个重要的脚本:
我们可以通过kafka-server-start.sh来启动服务。请注意,必须明确指定配置文件的路径,不带-daemon参数时是在前台启动的:
启动成功时可以看到提示:
通过jps可以看到Kafka的进程(另一个QuorumPeerMain是一个ZooKeeper):
也可以看到log.dirs中的内容: