目录

解压到安装目录

进入Kafka目录创建文件夹

进入config目录修改配置文件

编辑server.properties

编辑vim zookeeper.properties 文件

进入zookeeper目录创建myid文件,三台机器分别写入1,2,3

拷贝到另外两台机器

启动zookeeper

启动kafka

解压到安装目录

tar -zxvf /opt/soft/kafka_2.11-2.0.0.tgz -C /usr/local/src/

进入Kafka目录创建文件夹

cd /usr/local/src/kafka_2.11-2.0.0/
 mkdir logs
mkdir zookeeper

进入config目录修改配置文件

 cd /usr/local/src/kafka_2.11-2.0.0/config

编辑server.properties

vim server.properties
#broker的全局唯一编号,不能重复
broker.id=0

#下面加一个
delete.topic.enable=true

#改为logs路径
log.dirs=/usr/local/src/kafka_2.11-2.0.0/logs/

#改为slave:2181,slave1:2181,slve2:2181/kafka
zookeeper.connect=slave:2181,slave1:2181,slve2:2181/kafka

编辑vim zookeeper.properties 文件

vim vim zookeeper.properties 
#改为zookeeper路径
dataDir=/usr/local/src/kafka_2.11-2.0.0/zookeeper/

#改为100
maxClientCnxns=100

#在下面加上
tickTime=2000
initTime=10
syncLimit=5
server.1=slave01:2888:3888
server.2=slave02:2888:3888
server.3=slave03:2888:3888

进入zookeeper目录创建myid文件,三台机器分别写入1,2,3

vim myid
1

拷贝到另外两台机器

scp -r /usr/local/src/kafka_2.11-2.0.0/ slave1:/usr/local/src/
scp -r /usr/local/src/kafka_2.11-2.0.0/ slave2:/usr/local/src/

启动zookeeper

zookeeper-server-start.sh -daemon/usr/local/src/kafka_2.112.0.0/config/zookeeper.properties

启动kafka

kafka-server-start.sh -daemon /usr/local/src/kafka_2.11-2.0.0/config/server.properties

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐