原文鏈接：spring整合kafka_spring集成kafka-CSDN博客

1、導入依賴

<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId><version>2.5.10.RELEASE</version>
</dependency>

2、yml配置

spring: kafka:bootstrap-servers: localhost:9092    # kafka連接接地址consumer:group-id: test-consumer-group    # 消費者所屬消息組enable-auto-commit: true    #設置自動提交auto-commit-interval: 3000    #自動提交的間隔時間

3、測試

-生產者

@Component
class KafkaProduce{@Autowiredprivate KafkaTemplate kafkaTemplate;public void sendMessage(String topic, String content){kafkaTemplate.send(topic, content);}
}

-消費者

@Component
class kafkaConsumer{@KafkaListener(topics = {"test"})public void handleMessage(ConsumerRecord record){System.out.println(record.value());}
}

-測試方法

    @Autowiredprivate KafkaProduce kafkaProduce;@Testvoid TestKafka(){kafkaProduce.sendMessage("test", "nihao");kafkaProduce.sendMessage("test", "nihaoma");try {sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}}

也可以使用offset Explorer 2.3.2進行測試，使用方法見我的這篇博文：

offset explore 工具介紹（原kafka tool）_offset explorer-CSDN博客