部署&运维

下载

http://kafka.apache.org/downloads

安装

解压即可

配置

/config/server.properties（重要）
Kafka服务器配置
broker.id ：当前Kafka服务器在集群中的唯一ID
listeners ： 当前Kafka服务器监听的端口（默认9092）
zookeeper.connect ： 当前Kafka服务器连接的zookeeper地址（默认为localhost:2181）

/config/consumer.properites
消费者配置
/config/producer.properties
生产者配置

启动

  1. 注意事项
  • JDK路径中不能有空格或括号，不然会遇到以下情况：
F:\DataBase\kafka_2.12-3.0.0\bin\windows>zookeeper-server-start.bat ../../config/zookeeper.properties

此时不应有 \Java\jdk1.8.0_73\lib
  • JDK的bin文件夹下需要有server文件夹，若没有，则需要到jre/bin中拷贝过来，否则会遇到以下情况：
F:\DataBase\kafka_2.12-3.0.0\bin\windows>zookeeper-server-start.bat ../../config/zookeeper.properties

Error: missing `server' JVM at `F:\jdk\jdk1.8.0_60\bin\server\jvm.dll'.
Please install or use the JRE or JDK that contains these missing components.
  1. 启动Zookeeper
#在Kafka解压目录下，启动Kafka自带的Zookeeper
#Linux
bin/zookeeper-server-start.sh config/zookeeper.properties
#Windows
bin/windows/zookeeper-server-start.bat ../config/zookeeper.properties
  1. 启动Kafka服务器
#在Kafka解压目录下
bin/kafka-server-start.sh config/server.properties

Kafka管理

可使用以下Kafka管理工具：

Last Updated:
Contributors: dongyz8