kafka安装

安装kafaka前需要安装zookeeper,kafka的运行必须依赖 zookeeper

一、下载

前往官网下载二进制可执行文件 http://kafka.apache.org/downloads

lg: kafka_2.12-2.3.1.tgz

上传到服务器,然后解压,并移动动你想要放置的目录

1
2
tar -zxvf kafka_2.12-2.3.1.tgz
mv kafka_2.13-2.8.0 /opt/kafka-2.8.0

二、启动

1
2
3
4
5
6
7
8
9
10
11
# 启动kafka
./bin/kafka-server-start.sh ./config/server.properties

# 启动一个生产者
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

#启动一个消费者
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

# 后台启动
./bin/kafka-server-start.sh -daemon ./config/server.properties

三、配置kafka可以远程访问

修改配置文件 server.properties 添加下面这两行配置

1
2
3
4
#listeners=PLAINTEXT://:9092
listeners=PLAINTEXT://:9092
#advertised.listeners=PLAINTEXT://your.host.name:9092
advertised.listeners=PLAINTEXT://192.168.196.129:9092