单机版kafka的搭建 - 好文

环境 centos7 jdk1.8 zookeeper3.4.10 kafka2.11

操作前打开2181和9092端口

1.安装zookeeper
wget
http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz
tar -zxvf zookeeper-3.4.10.tar.gzcd zookeeper-3.4.10/conf
将zoo_sample.cfg复制一份改为zoo.cfg
cp zoo_sample.cfg zoo.cfg
编辑zoo.cfg
vim zoo.cfg
编辑之后的内容
tickTime=2000 initLimit=10 syncLimit=5 #目录自行创建 dataDir=/tmp/zookeeper
dataLogDir=/var/log/kafka/zk clientPort=2181 server.1=[你的host]:2888:3888
具体配置自行查阅相关资料

进入bin目录，启动，重启，停止，查看状态命令如下
./zkServer.sh start ./zkServer.sh stop ./zkServer.sh restart ./zkServer.sh
status若启动失败，查看配置文件中的日志文件夹是否创建

2.安装kafka
wget http://mirrors.hust.edu.cn/apache/kafka/1.1.0/kafka_2.11-1.1.0.tgztar
-zxvf kafka_2.11-1.1.0.tgz
进入目录，修改配置文件
cd kafka_2.11-1.1.0/configvim server.properties 打开注释
#listeners=PLAINTEXT://:9092
#advertised.listeners=PLAINTEXT://your.host.name:9092
进行相应的更改

更改zookeeper的配置，将localhost改为你的zookeeper地址，若zookeeper在本地可以不用修改

保存

启动kafka

进入bin目录执行如下命令
(./kafka-server-start.sh config/server.properties &)
保持后台运行

测试

创建一个名叫test的topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1
--partitions 1 --topic test查看所有的topic
./kafka-topics.sh --list --zookeeper localhost:2181发送消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
输入 hello kafka

接收消息
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
--from-beginning可以收到 hello kafka 的消息

参考http://kafka.apache.org/documentation/
<http://kafka.apache.org/documentation/>

热门工具换一换