欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

kafka安装及测试

程序员文章站 2022-06-17 17:50:26
...

1.http://apache.fayea.com/下载

jdk需要1.8以上版本,要不然会报错 java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 52.0

wget http://apache.fayea.com/kafka/1.1.0/kafka_2.12-1.1.0.tgz   

kafka安装及测试

2.解压tgz文件,进入kafka的bin目录(最新kafka自带zookeeper环境)

tar -zxvf kafka_2.12-1.1.0.tgz
cd kafka_2.12-1.1.0/bin

kafka安装及测试

3.启动zk

./zookeeper-server-start.sh ../config/zookeeper.properties &

kafka安装及测试

4.启动kafka

./kafka-server-start.sh ../config/server.properties &

kafka安装及测试

报错了,我把shizhan01 添加进/etc/hosts中,重新启动成功

kafka安装及测试

5.启动一个生产者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

kafka安装及测试

6.启动一个消费者

bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test1 --from-beginning
kafka安装及测试

7.在生产者输入hi kafka

kafka安装及测试

注:kafka异常退出重启会报错,删除/tmp、kafka-logs下的文件即可

Failed to acquire lock on file .lock in /tmp/kafka-logs

rm -rf /tmp/kafka-logs