原文链接：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{
@Autowired
private 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());
}
}-测试方法
@Autowired
private KafkaProduce kafkaProduce;
@Test
void TestKafka(){
kafkaProduce.sendMessage("test", "nihao");
kafkaProduce.sendMessage("test", "nihaoma");
try {
sleep(1000 * 20);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
也可以使用offset Explorer 2.3.2进行测试，使用方法见我的这篇博文：
