Centos 7.9 install kafka2.13-3.1.0

2022/2/12 7:18:23

本文主要是介绍Centos 7.9 install kafka2.13-3.1.0,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

一、下载需要的Kafka版本

Apache Kafkaicon-default.png?t=M0H8https://kafka.apache.org/

$ tar -xzf kafka_2.13-3.1.0.tgz
$ cd kafka_2.13-3.1.0

二、启动Kafka环境

注意:您的本地环境必须安装了 Java 8+ 。

运行以下命令以正确的顺序启动所有服务:

# Start the ZooKeeper service
# Note: Soon, ZooKeeper will no longer be required by Apache Kafka.
$ bin/zookeeper-server-start.sh config/zookeeper.properties

打开另一个终端会话并运行:

# Start the Kafka broker service
$ bin/kafka-server-start.sh config/server.properties

成功启动所有服务后,您将拥有一个正在运行并随时可用的基本 Kafka 环境。

注:启动后通过日志可以发现一个WARN的警告:

WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (static.38.81.243.136.clients.your-server.de/136.243.81.38:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

解决方法如下:

修改配置文件

vim config/server.properties

打开下面的注释:

listeners = PLAINTEXT://172.0.0.1:9092 

重新启动Kafka

# Start the Kafka broker service
$ bin/kafka-server-start.sh config/server.properties


这篇关于Centos 7.9 install kafka2.13-3.1.0的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!


扫一扫关注最新编程教程