ubuntu安装kafka

安装java

sudo apt-get update
sudo apt-get install openjdk-8-jdk
java -version

安装zookeeper

1. 下载zookeeper，目前比较稳定的zookeeper版本是3.7.0

手动下载地址：https://archive.apache.org/dist/zookeeper/zookeeper-3.7.0/
使用wget:wget https://archive.apache.org/dist/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

1. 放到ubuntu服务器上解压，或者第一步直接用wget

tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz

1. 解压后进入cd apache-zookeeper-3.7.0-bin/
2. 然后进入conf执行：mv zoo_sample.cfg zoo.cfg
3. 然后退出conf，进入bin文件执行

./zkServer.sh start

1. 默认端口是8080，如果启动失败执行下面命令查看启动失败原因

./zkServer.sh start-foreground

安装kafka

1. 下载，可以去这个网站自己下载 地址，然后放到自己的服务器上，也可以直接执行下面的wget直接拉去，如果去网站下载这个稳定版本，如下图

wget https://downloads.apache.org/kafka/3.2.3/kafka_2.13-3.2.3.tgz

1. 解压缩

tar -zxvf kafka_2.13-3.2.3.tgz

1. 解压后进入文件夹执行下面命令启动kafka

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

其实启动就是以来bin文件夹中的kafka-server-start.sh和config文件夹中的server.properties

主题

1. 启动主题，主题名称为：quickstart-events

bin/kafka-topics.sh --create --partitions 1--replication-factor 1--topic quickstart-events --bootstrap-server localhost:9092

1. 向主题里面发送消息

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

1. 向主题里面接受消息

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

配置环境变量

以后我们启动kafka，如果总是在kafka文件夹下，那么就会很麻烦，这时候，我们配置一下环境变量就可以了

1. vim ~/.bashrc
2. 添加如下语句，然后保存退出

export KAFKA_HOME=/root/home/kafka/kafka_2.13-3.2.3
export PATH=$KAFKA_HOME/bin:$PATH

1. 其中的/root/home/kafka/kafka_2.13-3.2.3是我自己的目录，要修改成自己的
2. 执行如下命令是环境变量生效：source ~/.bashrc
3. 然后就可以随便在终端使用如下命令了

kafka-topics.sh --create --partitions 1--replication-factor 1--topic quickstart-events --bootstrap-server localhost:9092

配置外网连接

1. 如果你是在你服务器搭建的kafka，那么想要本地连接的话，首先需要打开安全组配置9092，然后在config文件夹下执行

vim server.properties

1. 将这一行注释打开，并写上自己的服务器ip

advertised.listeners=PLAINTEXT://47.xxx.xxx.xxx:9092

1. 保存即可