在 Linux 上安装 Apache Kafka

在 Linux 上安装 Apache Kafka 的步骤如下：

### 前提条件

1. **Java**: Kafka 需要 Java 运行环境（JRE）。确保你已经安装了 Java 8 或更高版本。可以使用以下命令检查 Java 是否已安装：
   ```bash
   java -version
   ```

如果没有安装 Java，可以使用以下命令安装 OpenJDK：
   ```bash
   sudo apt update
   sudo apt install default-jdk
   ```

2. **Zookeeper**: Kafka 使用 Zookeeper 来管理集群。Kafka 自带了 Zookeeper，但你也可以单独安装。

### 安装步骤

1. **下载 Kafka**:
   访问 [Apache Kafka 的官方网站](https://kafka.apache.org/downloads) 下载最新版本的 Kafka。你可以使用 `wget` 命令下载：
   ```bash
   wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz
   ```

请根据需要替换为最新版本的下载链接。

2. **解压 Kafka**:
   使用以下命令解压下载的文件：
   ```bash
   tar -xzf kafka_2.13-3.5.0.tgz
   ```

3. **进入 Kafka 目录**:
   ```bash
   cd kafka_2.13-3.5.0
   ```

4. **启动 Zookeeper**:
   Kafka 自带了一个 Zookeeper 实例，可以使用以下命令启动：
   ```bash
   bin/zookeeper-server-start.sh config/zookeeper.properties
   ```

5. **启动 Kafka 服务器**:
   在另一个终端窗口中，启动 Kafka 服务器：
   ```bash
   bin/kafka-server-start.sh config/server.properties
   ```

6. **创建一个主题**:
   你可以创建一个 Kafka 主题来测试：
   ```bash
   bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
   ```

7. **生产者和消费者测试**:
   - **启动生产者**:
     ```bash
     bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
     ```
     输入一些消息并按 Enter 发送。

- **启动消费者**:
     在另一个终端窗口中，启动消费者：
     ```bash
     bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
     ```

### 停止 Kafka 和 Zookeeper

要停止 Kafka 和 Zookeeper，可以使用以下命令：

- 停止 Kafka：
  ```bash
  bin/kafka-server-stop.sh
  ```

- 停止 Zookeeper：
  ```bash
  bin/zookeeper-server-stop.sh
  ```

### 注意事项

- 确保你的防火墙允许 Kafka 和 Zookeeper 使用的端口（默认是 9092 和 2181）。
- 你可以根据需要修改 `config/server.properties` 和 `config/zookeeper.properties` 文件以进行更详细的配置。

如果你有其他问题或需要进一步的帮助，请告诉我！

相关推荐

近期文章