安装Java环境
在oracle官网下载jdk1.8 ，官网地址https://www.oracle.com/java/technologies/downloads/#java8。
上传JDK
下载完成后上传到用户根目录并重命名为jdk.tar.gz：
sudo mkdir -p /opt/jdk
tar -xf jdk.tar.gz -C /opt/jdk配置环境变量
echo "" >> /etc/profile
echo "# JDK 8 Environment Variables" >> /etc/profile
echo "export JAVA_HOME=/opt/jdk" >> /etc/profile
echo "export PATH=$PATH:$JAVA_HOME/bin" >> /etc/profile
source /etc/profile验证安装
[root@test1 ~]# java -version
java version "1.8.0_391"
Java(TM) SE Runtime Environment (build 1.8.0_391-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.391-b13, mixed mode)安装Kafka最新版本
在写这篇文章的时候，目前最新版本是3.6.0版本
下载最新版本
cd /opt && wget https://downloads.apache.org/kafka/3.6.0/kafka_2.13-3.6.0.tgz 解压
tar -xzf kafka_2.13-3.6.0.tgz配置Kafka
-
1. 进入解压目录：
cd kafka_2.13-3.6.0 -
2. 打开
config/server.properties文件进行配置：vi config/server.properties根据自己的需求进行调整：
-
•
broker.id：Kafka代理的唯一标识符。 -
•
listeners：Kafka监听器的主机和端口。默认情况下，Kafka使用PLAINTEXT://:9092。改成PLAINTEXT://「kafka主机的IP」:9092。 -
•
log.dirs：Kafka日志文件的目录。 -
•
zookeeper.connect：Zookeeper的主机和端口。默认情况下，Kafka使用localhost:2181。
启动Kafka
# 先启动 zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 再启动 kafka
bin/kafka-server-start.sh -daemon config/server.properties验证
以下的所有操作都是在/opt/kafka_2.13-3.6.0中进行：
-
1. 创建主题
bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 -
2. 发布消息到
test-topic主题：bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092 -
3. 在新终端窗口中，消费来自
test-topic主题的消息：bin/kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
欢迎大家关注我的公众号，将会为大家推荐更优质的内容！
原文始发于微信公众号（青檬小栈）：搭建Kafka最新版本
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/213243.html
