安装

安装之前先安装好java环境,准备好一台zookeeper,kafka是依靠zookeeper做集群的。

下载地址http://kafka.apache.org/downloads ,目前最新稳定版本是2.3.x,建议下载scala 2.12版本,也即下载后是kafka_2.12-2.3.1.tgz,然后解压。

修改config/server.properties文件:

broker.id=0 # 集群中的broker id是唯一的,例如0,1,2,它必须是集群内唯一数字

# 特别说明,类似容器内网时,需要暴露外网ip,则可以用advertised.listeners来满足这个需求

zookeeper.connect=zk的ip地址,建议自己建一个

启动:

./kafka-server-start.sh -daemon ../config/server.properties
# 启动之后会监听在端口9092  (如果启动失败,则把-daemon去掉,看控制台输出)

这个可以看出kafka的集群方式很容易搭建出来,围绕zk就能搭建出一个分布式集群出来。

特别说明,kafka对端口映射并不友好,它内部还是维护自己的ip地址,也就是说advertised.listeners还是得用上,不能只是简单的端口映射。

文档更新时间: 2019-10-25 16:34   作者:nick