如何在Linux下安装Kafka:完整教程分享

1. 先决条件

  • 操作系统:Ubuntu 18.04或更高版本
  • Java:JDK 8或更高版本
  • Apache Kafka:2.13或更高版本
  • ZooKeeper:3.4.14或更高版本

2. 安装Java

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

登录后复制

3. 安装Apache Kafka

wget https://dlcdn.apache.org/kafka/2.13/kafka_2.13-3.3.1.tgz
tar -xvzf kafka_2.13-3.3.1.tgz

登录后复制

4. 安装ZooKeeper

wget https://dlcdn.apache.org/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
tar -xvzf zookeeper-3.4.14.tar.gz

登录后复制

5. 配置Kafka

cd kafka_2.13-3.3.1
cp config/server.properties config/server.properties.orig
vim config/server.properties

登录后复制

修改以下配置:

broker.id=0
listeners=PLAINTEXT://localhost:9092
zookeeper.connect=localhost:2181

登录后复制

6. 配置ZooKeeper

cd zookeeper-3.4.14
cp conf/zoo.cfg conf/zoo.cfg.orig
vim conf/zoo.cfg

登录后复制

修改以下配置:

dataDir=/tmp/zookeeper
clientPort=2181

登录后复制

7. 启动ZooKeeper

cd zookeeper-3.4.14
bin/zkServer.sh start

登录后复制

8. 启动Kafka

cd kafka_2.13-3.3.1
bin/kafka-server-start.sh config/server.properties

登录后复制

9. 创建Topic

bin/kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1

登录后复制

10. 发送消息

bin/kafka-console-producer.sh --topic my-topic --message "Hello, world!"

登录后复制

11. 消费消息

bin/kafka-console-consumer.sh --topic my-topic --from-beginning

登录后复制

12. 停止Kafka

bin/kafka-server-stop.sh

登录后复制

13. 停止ZooKeeper

bin/zkServer.sh stop

登录后复制

以上就是分享Linux下安装Kafka的详细教程的详细内容,更多请关注小闻网其它相关文章!

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。