1 总体说明

    分为两种类型的集成

  以消费者的形式集成Kafka

  以生产者的形式集成Kafka

 2 以消费者的形式集成Kafka

    2.1 引入pom

  <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <!-- spring boot版本 -->
        <spring.boot.version>2.1.3.RELEASE</spring.boot.version>
    </properties>
    <dependencyManagement>
        <dependencies>
            <!--集成 spring boot 框架-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring.boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
        </dependency>
    </dependencies>

      

   2.2 编写配置文件

spring:
  kafka:
    consumer:
      group-id: 消费组ID
      auto-offset-reset: latest
      enable-auto-commit: true
      bootstrap-servers: kafka地址
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer

        2.3  编写消费类

         

@Component
public class Consumer{



    @KafkaListener(topics = "topic值")
    public void listen(ConsumerRecord<String, byte[]> record) {

    }

}