首页 > 技术文章 > Spring Kafka

zhya 2018-10-29 13:47 原文

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,并开启

 

推荐阅读