一、安装
kafka可以通过官网下载:
https://kafka.apache.org/downloads
kafka根据Scala版本不同,又分为多个版本,我不需要使用Scala,所以就下载官方推荐版本kafka_2.12-2.4.0.tgz。
使用tar -xzvf kafka_2.12-2.4.0.tgz 解压
为了使用方便,可以创建软链接kafka0
二·kafka配置
kafka的配置文件在config/server.properties文件中,主要修改参数如下,更具体的参数说明以后再整理下。
broker.id是kafka broker的编号,集群里每个broker的id需不同。我是从0开始。
listeners是监听地址,需要提供外网服务的话,要设置本地的IP地址
log.dirs是日志目录,需要设置
设置Zookeeper集群地址,我是在同一个服务器上搭建了kafka和Zookeeper,所以填的本地地址
num.partitions 为新建Topic的默认Partition数量,partition数量提升,一定程度上可以提升并发性



