下载安装包

Kafka 下载地址: 官网下载

因为Kafka是由Scala语言编写的,图中的2.11和2.12指的是Scala的版本,意思就是由Scala2.11或2.12编译出的Kafka2.3.1二进制版本,而2.3.1才是Kafka的版本。这里我们直接下载二进制版本,如果下载源码版本需要自己去编译。

解压

> tar -xzf kafka
> cd kafka

修改配置文件

修改config下的server.properties文件

broker.id=1 // broker.id在每个节点上是唯一的
log.dirs=/opt/data/kafka //log.dirs指定的kafka中的数据的存放位置,默认的tmp目录会定期清空,所以需要修改,而且指定的目录需要在启动kafka之前创建好
zookeeper.connect=localhost:2181 // zookeeper.connect如果不指定,将使用kafka自带的zookeeper
listeners = PLAINTEXT://localhost:9092 // 服务监听端口

启动服务

  1. 启动zookeeper
> bin/zookeeper-server-start.sh config/zookeeper.properties
  1. 启动kafka
> bin/kafka-server-start.sh config/server.properties
文档更新时间: 2020-04-01 12:00   作者:朱业成