Spring Cloud 集成kafka

pom 依赖

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

yml文件配置

kafka:bootstrap-servers: 172.31.209.90:9092 #(kafka生产集群ip+port端口)producer:buffer-memory: 40960retries: 0batch-size: 4096properties:linger.ms: 1consumer:enable-auto-commit: true #(是否自动提交)auto-commit-interval: 100msauto-offset-reset: latest #(实时生产，实时消费，不会从头开始消费)group-id: test #(消费组)key-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializer

监听器

Slf4j
@Component
public class EhrAgreementListener {@KafkaListener(topics = {"annul"}, groupId = "myContainer2")public void annul1(ConsumerRecord<String, String> record) {log.info("groupId = myContainer2, message = " + record.toString());}@KafkaListener(topics = {"signed"}, groupId = "myContainer2")public void signed2(ConsumerRecord<String, String> record) {log.info("groupId = myContainer2, message = " + record.toString());}}

新建个controller 写个方法，项目启动直接成功
@Autowired
private KafkaTemplate kafkaTemplate;

public void sendTest(String msg) {
kafkaTemplate.send(“signed”, msg);
}

Spring Cloud 集成kafka相关推荐

spring cloud微服务分布式云架构 - Spring Cloud集成项目简介
Spring Cloud集成项目有很多,下面我们列举一下和Spring Cloud相关的优秀项目,我们的企业架构中用到了很多的优秀项目,说白了,也是站在巨人的肩膀上去整合的.在学习Spring Clo ...
关于SpringCloud微服务云架构构建B2B2C电子商务平台之- Spring Cloud集成项目简介（三）...
2019独角兽企业重金招聘Python工程师标准>>> Spring Cloud集成项目有很多,下面我们列举一下和Spring Cloud相关的优秀项目,我们的企业架构中用到了很多的 ...
（三）java版spring cloud+spring boot 社交电子商务平台 - Spring Cloud集成项目简介
2019独角兽企业重金招聘Python工程师标准>>> 电子商务平台源码请加企鹅求求:一零三八七七四六二六.Spring Cloud集成项目有很多,下面我们列举一下和Spring C ...
spring cloud微服务分布式云架构 - Spring Cloud集成项目简介(三)
点击上面免费订阅本账号! 本文作者:it菲菲原文:https://yq.aliyun.com/articles/672242 点击阅读全文前往 Spring Cloud集成项目有很多,下面我们列举 ...
spring cloud集成Eureka
spring cloud整合Eureka 文章目录 spring cloud整合Eureka Server模块的搭建 pom.xml配置启动类配置 application.yam配置查看Eurek ...
spring cloud 集成consul
spring cloud 集成consul pom.xml配置 <dependency><groupId>org.springframework.cloud</group ...
spring cloud 集成sentinel 报错 Failed to introspect Class
今天在 spring cloud 集成sentinel 的时候发现报错 Failed to introspect Class [org.springframework.boot.autoconfi ...
spring cloud 集成 seata 分布式事务
spring cloud 集成 seata 分布式事务基于 seata-server 1.6.x 序言下载 seata-server 准备一个数据库 seata 专门为 seata-server ...
spring cloud stream kafka 处理消息
spring cloud stream kafka <dependency><groupId>org.springframework.cloud</groupId> ...

Spring Cloud 集成kafka

Spring Cloud 集成kafka相关推荐

最新文章

热门文章