您的位置:

如何在Linux上安装Kafka

Kafka是由Apache软件基金会开发的一个开源事件流处理平台,它由数个Broker节点组成,支持发布-订阅消息服务。

一、安装Java开发环境

在安装Kafka之前,需要先安装Java开发环境,可以通过以下命令来检查是否已经安装了Java:

java -version

如果没有安装Java,可以使用以下命令在Ubuntu上安装:

sudo apt update
sudo apt install default-jre
sudo apt install default-jdk

在CentOS上安装Java:

sudo yum install java-1.8.0-openjdk

二、下载和安装Kafka

可以从Kafka的官网下载Kafka二进制文件并解压缩。

wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz
tar -xzf kafka_2.12-2.6.0.tgz
cd kafka_2.12-2.6.0

三、启动Kafka Broker

在启动Kafka之前,可以在config/server.properties文件中修改一些配置项,比如broker.id、listeners、log.dirs等等。

接下来,可以使用以下命令启动Kafka Broker:

bin/kafka-server-start.sh config/server.properties

在启动之后,可以使用以下命令来检查Kafka是否正常启动:

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

如果显示无误,说明Kafka已经正常启动。

四、创建和使用Topic

在Kafka中,可以使用以下命令来创建一个Topic:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

可以使用以下命令来查看已经创建的Topics:

bin/kafka-topics.sh --list --zookeeper localhost:2181

可以使用以下命令来往Topic中发送消息:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

可以使用以下命令来接收Topic中的消息:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

五、Kafka常用命令

  • 创建Topic: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  • 查看Topic列表: bin/kafka-topics.sh --list --zookeeper localhost:2181
  • 查看Topic详情: bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
  • 往Topic中写入消息: bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
  • 从Topic中读取消息: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  • 删除Topic: bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
  • 开启Kafka管理功能: bin/kafka-server-start.sh config/server.properties --override delete.topic.enable=true