centos7单机安装kafka，进行生产者消费者测试

kafka安装与测试


1、配置JDK环境

安装jdk就不写了

2、安装kafka

下载地址：http://kafka.apache.org/downloads

cd /opt
wget http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
tar zxvf kafka_2.11-2.3.0.tgz
mv kafka_2.11-2.3.0 /usr/local/apps/
cd /usr/local/apps/
ln -s kafka_2.11-2.3.0 kafka

3、启动测试

（1）启动Zookeeper服务

cd /usr/local/apps/kafka
#执行脚本
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
#查看进程
jps

（2）启动单机Kafka服务

#执行脚本
bin/kafka-server-start.sh config/server.properties
#后端执行
#bin/kafka-server-start.sh config/server.properties &
#查看进程
jps

（3）创建topic进行测试

#执行脚本
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

（4）查看topic列表

#执行脚本
bin/kafka-topics.sh --list --zookeeper localhost:2181
输出：test

（5）生产者消息测试

#执行脚本(使用kafka-console-producer.sh 发送消息)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

（6）消费者消息测试

#执行脚本(使用kafka-console-consumer.sh 接收消息并在终端打印)
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

删除topic

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

查看kafka进程:

ps -ef|grep kafka