Spring Kafka

spring和kafka结合使用

官方文档

https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-messaging.html#boot-features-amqp

 

全量配置

https://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html

 

1.添加spring-kafka依赖，使用最新版以兼容最新的kafka

 

2.基础配置

3.topic

注入NewTopic类型的Bean，即可在系统启动时自动创建topic，如果topic已存在则不继续创建

 4.producer

使用起步配置后，可以直接注入kafkaTemplate，通过send方法发布消息到某个主题

 5.consumer

使用KafkaListener注解即可开启消费

6.Stream

先启用kafkaStream，然后注入stream配置

注入streamConfig，通过StreamBuilder即可创建Stream，并开启