Springboot集成kafka简单应用(相对实用)

1. 集成的首先要引入kafka POM包

      
			org.springframework.kafka
			spring-kafka
		

2. 修改application.yml配置

server:
  port: 8090
spring:
  kafka:
    bootstrap-servers: localhost:9092
    producer:
      retries: 0
      batch-size: 16384
      buffer-memory: 33554432
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
      acks: 1
    consumer:
      properties:
         group:
           id: defaultConsumerGroup
      auto-commit-interval: 1S
      auto-offset-reset: earliest
      enable-auto-commit: false
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer