Spring Cloud Stream Binder for Apache Kafka 使用教程

2024-08-07 01:30:19作者：翟江哲Frasier

1. 项目的目录结构及介绍

目录结构

spring-cloud-stream-binder-kafka/
├── github/
│   └── ISSUE_TEMPLATE/
├── docs/
├── spring-cloud-starter-stream-kafka/
├── spring-cloud-stream-binder-kafka-core/
├── spring-cloud-stream-binder-kafka-streams/
├── spring-cloud-stream-binder-kafka/
├── .gitignore
├── jdk8/
├── settings.xml
├── LICENSE
├── README.adoc
├── mvnw
├── mvnw.cmd
├── pom.xml
└── update-version.sh

目录介绍

github/ISSUE_TEMPLATE/: 存放GitHub Issue模板。
docs/: 存放项目文档。
spring-cloud-starter-stream-kafka/: Kafka Starter依赖。
spring-cloud-stream-binder-kafka-core/: Kafka Binder核心代码。
spring-cloud-stream-binder-kafka-streams/: Kafka Streams Binder代码。
spring-cloud-stream-binder-kafka/: Kafka Binder代码。
.gitignore: Git忽略文件配置。
jdk8/: JDK 8相关配置。
settings.xml: Maven配置文件。
LICENSE: 项目许可证。
README.adoc: 项目说明文档。
mvnw: Maven包装器脚本。
mvnw.cmd: Maven包装器脚本（Windows）。
pom.xml: 项目依赖管理文件。
update-version.sh: 更新版本脚本。

2. 项目的启动文件介绍

启动文件

项目的启动文件通常位于spring-cloud-stream-binder-kafka模块下的src/main/java目录中。具体路径可能因项目结构而异，但通常会包含一个或多个启动类。

示例启动类

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class KafkaApplication {
    public static void main(String[] args) {
        SpringApplication.run(KafkaApplication.class, args);
    }
}

启动类介绍

@SpringBootApplication: 这是一个组合注解，包含了@Configuration、@EnableAutoConfiguration和@ComponentScan，用于简化Spring Boot应用的配置。
SpringApplication.run(): 启动Spring Boot应用。

3. 项目的配置文件介绍

配置文件

项目的配置文件通常位于src/main/resources目录下，常见的配置文件包括application.properties或application.yml。

示例配置文件 (`application.yml`)

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: my-topic
          contentType: application/json
        output:
          destination: my-topic
          contentType: application/json
      kafka:
        binder:
          brokers: localhost:9092
          autoCreateTopics: true

配置文件介绍

spring.cloud.stream.bindings: 定义输入和输出绑定。
- destination: Kafka主题名称。
- contentType: 消息内容类型。
spring.cloud.stream.kafka.binder: Kafka Binder配置。
- brokers: Kafka broker地址。
- autoCreateTopics: 是否自动创建主题。