MultiKafkaConsumerStarter 项目利用教程

MultiKafkaConsumerStarter 项目利用教程

    MultiKafkaConsumerStarter   

项目地点: https://gitcode.com/gh_mirrors/mu/MultiKafkaConsumerStarter   
1. 项目目录结构及介绍

1. MultiKafkaConsumerStarter/
2. ├── src/
3. │   ├── main/
4. │   │   ├── java/
5. │   │   │   ├── com/
6. │   │   │   │   ├── example/
7. │   │   │   │   │   ├── config/
8. │   │   │   │   │   │   ├── KafkaConsumerConfig.java
9. │   │   │   │   │   ├── consumer/
10. │   │   │   │   │   │   ├── MultiKafkaConsumer.java
11. │   │   │   │   │   ├── starter/
12. │   │   │   │   │   │   ├── MultiKafkaConsumerStarter.java
13. │   │   ├── resources/
14. │   │   │   ├── application.properties
15. ├── README.md
16. ├── 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

1. package com.example.starter;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. @SpringBootApplication
7. public class MultiKafkaConsumerStarter {
8.     public static void main(String[] args) {
9.         SpringApplication.run(MultiKafkaConsumerStarter.class, args);
10.     }
11. }

复制代码

启动文件阐明

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

3. 项目设置文件介绍

application.properties

1. spring.kafka.bootstrap-servers=localhost:9092
2. spring.kafka.consumer.group-id=my-group
3. spring.kafka.consumer.auto-offset-reset=earliest
4. spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
5. 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   

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。