kafka在linux下的配置与启动

一、下载与安装

http://kafka.apache.org/downloads.html 下载binary版本

解压：tar -zxvf kafka-2.2.0-src.tgz

具体请参考本站zookeeer的配置与启动

创建日志目录 logs

设置config/server.properties文件，修改各项配置

broker.id=0 #根据服务器情况修改值，可以为0,1,2…，broker值，需要是独一无二的

listeners=PLAINTEXT://10.16.137.80:9092

log.dirs=/usr/local/kafka/logs #logs文件路径

num.partitions=2 #分区数量

zookeeper.connect=192.168.24.128:2181, 192.168.24.129:2181, 192.168.24.130:2181 #zookeeper服务器url

启动命令：

./kafka_2.11-2.2.0/bin/kafka-server-start.sh -daemon kafka_2.11-2.2.0/config/server.properties

如果需要启动多个，请复制多个server.properties文件，并为每个配置不同的broker.id值

测试kafak生产和消费消息：

四、常见错误

1）Classpath is empty. Please build the project first e.g. by running ‘./gradlew jar -PscalaVersion=2.12.8’

listeners=配置不对，或者zookeeper.connect连接不对

重要的是，可能是你下载了source代码，需要下载binary版本

2)Exception in thread “main” java.lang.UnsupportedClassVersionError: org/apache/kafka/common/utils/KafkaThread : Unsupported major.minor version 52.0

java 版本太低了，需要升级java版本