【Spring Cloud Alibaba】3.新版SpringCloudAlibaba整合Kafka

一、背景

废话不多说，直接上代码

二、pom.xml

    1.8
    1.8
    8
    8

    2.5.5
    2020.0.4
    3.0.4
    2021.1
    1.2.73
    3.1.4
    3.1.4




    
        
        
            org.springframework.boot
            spring-boot-dependencies
            ${spring.boot.version}
            pom
            import
        

        
        
            org.springframework.cloud
            spring-cloud-dependencies
            ${spring.cloud.version}
            pom
            import
        

        
        
            com.alibaba.cloud
            spring-cloud-alibaba-dependencies
            ${alibaba.cloud.version}
            pom
            import
        

        
        
            org.springframework.cloud
            spring-cloud-stream-dependencies
            ${stream.cloud.version}
            pom
        

        
        
            org.springframework.cloud
            spring-cloud-starter-stream-kafka
            ${kafka.cloud.version}
        
    




    
    
        org.springframework.kafka
        spring-kafka
    

三、配置文件

spring.kafka.bootstrap-servers = 127.0.0.1:9092,127.0.0.2:9092
spring.kafka.producer.acks = 1
spring.kafka.producer.retries = 3
spring.kafka.producer.batch-size = 16384
spring.kafka.producer.key-serializer = org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer = org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.enable-auto-commit = true
spring.kafka.consumer.key-deserializer = org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer = org.apache.kafka.common.serialization.StringDeserializer