从kafka官网上下载kafka的二进制安装包,下载地址是:https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz,下载下来之后进行解压。
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz
接着对文件进行解压。
????????sudo tar -zvxf kafka_2.12-2.4.0.tgz -C? /opt/
提取文件成功之后,接着创建一个文件的软连接,这样可以方便进行kafka的升级。
????????sudo ln -s /opt/kafka_2.12-2.4.0 /opt/kafka
接下来,进入到kafka目录下,启动kafka,启动kafka之前得先启动zookeeper。
????????????sudo ./zookeeper-server-start.sh ../config/zookeeper.properties
接着在开启一个shell进行启动kafka。
????????????sudo ./kafka-server-start.sh ../config/server.properties
由于通过上面的方式启动不是很方便,接下来就配置系统单元服务进行启动kafka和zookeeper。
按照以下方式创建zookeeper.service系统服务单元。
[root@localhost ~]$sudo? vi /etc/systemd/system/zookeeper.service
[Unit]
Description=Apache Zookeeper server
Documentation=http://zookeeper.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal
User=root
Group=root
[Install]
WantedBy=multi-user.target
保存完成之后,来启动验证一下是否配置成功。
????????systemctl start zookeeper
????????systemctl status zookeeper
????????systemctl start zookeeper
接着在配置一下kafka服务器的系统服务单元。
[root@localhost ~]$ sudo vi /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka Server
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service
[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
配置完成之后,接着来启动kafka。
? ? ? ? systemctl start kafka
? ? ? ? systemctl status kafka
? ? ? ? systemctl stop kafka
创建成功之后,接下来,测试一下是否安装成功。
测试之前先通过kafka创建一个topic。进入到kafka目录下,接着通过下面命令创建一个kafka topic。
????????????bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testTopic
查看创建了多少个topic,可以使用以下命令进行查看。
????????????????bin/kafka-topics.sh --list --zookeeper localhost:2181
接下来通过生产者进行发送消息。
????????????bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic
接着创建一个消费者来进行接收消息。
????????????bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning
通过以上步骤,就成功安装kafka了,这个时候就可以通过java开发工具连接进行开发了。