搭建单机Kafka(适用服务器)

搭建单机Kafka(适用服务器) 已有环境

已搭建Zookeeper 并确保zookeeper已启动

环境准备

Kafka kafka_2.11-1.0.0.tgz压缩包 添加链接描述

上传服务器

tar -xvf kafka_2.11-1.0.0.tgz
mv kafka_2.11-1.0.0 kafka  //文件夹更名
mkdir log.dirs=/usr/local/kafka/kafka-logs   ---创建存放kafka数据路径

修改配置文件

vi config/server.properties
需要修改属性
1 boroker.id = 0  //可自定义 不重复即可
2 listeners =  PLAINTEXT://9092    ----去除“#”即可
3 log.dirs=/usr/local/kafka/kafka-logs    ----创建存放数据目录
4 zookeeper.connect = zk地址:端口号   ---修改为自己的zookeeper地址+端口
5  zookeeper.connection.timeout.ms= 6000  ---可修改为30000

服务启动

cd bin  
sh kafka-server-start.sh ../config/server.properties   ---启动kafka服务

安装验证

当前 *** 作 在/bin目录下
----zookeeper上创建一个topic partition数为1 
sh kafka-topics.sh --zookeeper zk地址:端口 --create --replication-factor 1 --partitions 1 --topic first 

开启生产者 :  sh kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first
开启消费者:  sh kafka-console-consumer.sh --bootstrap-server  127.0.0.1:9092 --topic first -- from beginning

防火墙允许端口访问

#允许端口开放
firewall-cmd --zone=public --add-port=9092/tcp --permanent

远程可访问