MultiKafkaConsumerStarter 项目使用教程

MultiKafkaConsumerStarter 项目使用教程

MultiKafkaConsumerStarter 项目地址: https://gitcode.com/gh_mirrors/mu/MultiKafkaConsumerStarter

1. 项目目录结构及介绍

MultiKafkaConsumerStarter/
├── src/
│   ├── main/
│   │   ├── java/
│   │   │   ├── com/
│   │   │   │   ├── example/
│   │   │   │   │   ├── config/
│   │   │   │   │   │   ├── KafkaConsumerConfig.java
│   │   │   │   │   ├── consumer/
│   │   │   │   │   │   ├── MultiKafkaConsumer.java
│   │   │   │   │   ├── starter/
│   │   │   │   │   │   ├── MultiKafkaConsumerStarter.java
│   │   ├── resources/
│   │   │   ├── application.properties
├── README.md
├── pom.xml

目录结构说明

• src/main/java: 存放项目的Java源代码。 - com.example.config: 存放Kafka消费者配置相关的类。- com.example.consumer: 存放Kafka消费者实现类。- com.example.starter: 存放项目启动类。
• src/main/resources: 存放项目的配置文件。
• README.md: 项目说明文档。
• pom.xml: Maven项目配置文件。

2. 项目启动文件介绍

MultiKafkaConsumerStarter.java

package com.example.starter;

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

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

启动文件说明

• MultiKafkaConsumerStarter.java 是项目的启动类，使用Spring Boot框架。
• @SpringBootApplication 注解用于自动配置Spring Boot应用。
• SpringApplication.run 方法用于启动Spring Boot应用。

3. 项目配置文件介绍

application.properties

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

配置文件说明

• spring.kafka.bootstrap-servers: Kafka集群的地址。
• spring.kafka.consumer.group-id: Kafka消费者组的ID。
• spring.kafka.consumer.auto-offset-reset: 消费者偏移量的重置策略，earliest表示从最早的偏移量开始消费。
• spring.kafka.consumer.key-deserializer: 消息键的反序列化器。
• spring.kafka.consumer.value-deserializer: 消息值的反序列化器。

通过以上配置，项目可以连接到Kafka集群并消费消息。

MultiKafkaConsumerStarter 项目地址: https://gitcode.com/gh_mirrors/mu/MultiKafkaConsumerStarter