中间件 | Kafka - [安装 & 配置 & 启动]

Kafka是一种高吞吐量、可持久化、分布式消息系统，属于Apache软件基金会。

安装Kafka

1. 确保你已经安装了Java Development Kit (JDK)。

2. 下载并解压Kafka到你的系统上。

   
   
   
   wget https://www.apache.org/dyn/closer.cgi?path=/kafka/2.4.1/kafka_2.13-2.4.1.tgz
   tar -xzf kafka_2.13-2.4.1.tgz
   cd kafka_2.13-2.4.1

配置Kafka

1. 打开Kafka配置文件config/server.properties。
2. 修改配置项log.dirs指定日志存储目录。
3. 修改配置项zookeeper.connect指定Zookeeper连接字符串。

启动Kafka

1. 启动Zookeeper服务。

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

2. 启动Kafka服务。

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

检查Kafka服务状态

1. 创建一个测试主题。

   
   
   
   bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

2. 列出所有主题。

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

3. 启动生产者客户端。

   
   
   
   bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

4. 启动消费者客户端。

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

以上步骤可以帮助你安装、配置和启动Kafka服务，并通过生产者和消费者客户端进行基本的消息传递测试。