一、安装Java环境
1、首先检查操作系统中是否已经安装好了Java环境。在终端输入命令：
java -version如果操作系统尚未安装Java环境，会提示“Command not found”的信息。
2、安装OpenJDK：
sudo apt-get update
sudo apt-get install openjdk-8-jdk3、验证Java安装是否成功：
java -version验证成功后，会显示Java的版本信息。
二、下载和解压缩Kafka
1、前往Apache Kafka官网下载kafka的压缩包，最好选择稳定版本:
https://kafka.apache.org/downloads
2、下载完成后，进入下载目录，解压缩该文件：
tar -xzf kafka_2.13-2.8.0.tgz3、切换到Kafka目录:
cd kafka_2.13-2.8.0三、启动Kafka服务器
1、我们需要启动3个Kafka服务，Zookeeper服务和两个Broker服务:
bin/zookeeper-server-start.sh config/zookeeper.propertiesbin/kafka-server-start.sh config/server.properties再启动一个Broker节点
bin/kafka-server-start.sh config/server-1.properties再启动一个服务
bin/kafka-server-start.sh config/server-2.properties这样就启动好了Kafka服务器
四、创建topic
1、使用如下命令创建一个名为test的topic：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test其中，–replication-factor表示副本因子，即一个消息被保存在几个Broker节点上，–partitions表示分区数，可根据需求来定。
2、使用如下命令查看已存在的topic列表：
bin/kafka-topics.sh --list --zookeeper localhost:2181五、启动生产者和消费者
1、启动生产者：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test输入消息后，回车即可发送至Kafka。
2、启动消费者：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning–from-beginning代表从头开始消费。
六、清除数据和关闭服务
1、清除数据：
rm -rf /tmp/kafka-logs/*2、关闭Kafka服务：
bin/kafka-server-stop.sh3、关闭Zookeeper服务：
bin/zookeeper-server-stop.sh总结
本篇文章简要介绍了在Ubuntu上安装Apache Kafka的详细步骤，包括安装Java环境、下载和解压缩Kafka、启动Kafka服务器、创建topic、启动生产者和消费者等。
原创文章，作者：YBPGC，如若转载，请注明出处：https://www.506064.com/n/333074.html
微信扫一扫 
支付宝扫一扫 