Kafka依赖如何安装

Kafka 依赖的安装方式取决于你的使用场景（如 Java 项目依赖、Scala 项目、Python 客户端 等）。以下是常见场景的安装方法：

一、Java 项目中使用 Kafka（最常见）

1. Maven 项目

在 pom.xml 中添加 Kafka 客户端依赖：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.6.1</version> <!-- 建议使用最新稳定版 -->
</dependency>

如果你想使用 Kafka Streams：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams</artifactId>
    <version>3.6.1</version>
</dependency>

2. Gradle 项目

在 build.gradle 中添加：

dependencies {
    implementation 'org.apache.kafka:kafka-clients:3.6.1'
}

二、Scala 项目

如果你使用 Scala 并需要 Kafka 核心库（一般不直接依赖，除非开发 Kafka 内部组件）：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.13</artifactId>
    <version>3.6.1</version>
</dependency>

_2.13 表示 Scala 2.13 版本

三、Python 客户端（kafka-python）

如果你使用 Python：

pip install kafka-python

或（更推荐，性能更好）：

pip install confluent-kafka

示例：

from kafka import KafkaConsumer

consumer = KafkaConsumer('test-topic', bootstrap_servers='localhost:9092')

四、本地安装 Kafka 服务（不是依赖）

如果你是 部署 Kafka 服务，而不是写代码：

1. 下载 Kafka

wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1

2. 启动 Zookeeper（旧版本）或 KRaft（新版本）

# 启动 Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

# 启动 Kafka
bin/kafka-server-start.sh config/server.properties

五、Spring Boot + Kafka

如果你使用 Spring Boot：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

六、版本选择建议

如果你能告诉我：

• 使用语言（Java / Python / Go / Scala）
• 是否 Spring / Spring Boot
• 是写代码还是部署 Kafka

我可以给你 更精确的依赖配置示例 ✅