Spring Cloud 集成kafka

古城微笑少年丶 2021-11-05 15:22 506阅读 0赞

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: 40960
          retries: 0
          batch-size: 4096
          properties:
            linger.ms: 1
        consumer:
          enable-auto-commit: true #(是否自动提交)
          auto-commit-interval: 100ms
          auto-offset-reset: latest #(实时生产，实时消费，不会从头开始消费)
          group-id: test #(消费组)
          key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          value-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);
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，506人围观）

还没有评论，来说两句吧...

相关阅读

相关 java——spring boot集成kafka——spring boot集成kafka

引入依赖： ![3dddecb3c41fcb522c3c5652a0332294.png][] <dependency> <groupId>or

野性酷女/ 2023年09月30日 21:53/ 0 赞/ 45 阅读

相关 Kafka spring 集成

pom.xml: ![复制代码][copycode.gif] <dependency> <groupId>org.apache.ka

╰+攻爆jí腚メ/ 2022年06月17日 10:55/ 0 赞/ 168 阅读

相关 Spring Cloud 集成 kafka

kafka的安装部署请参考：[kafka安装部署][kafka] 1、在pom.xml里面添加kafka的maven依赖 <dependency> <gr

矫情吗；*/ 2022年06月15日 12:42/ 0 赞/ 535 阅读

相关 Spring Cloud Stream + Kafka

> SpringCloudStream是一个构建消息驱动的微服务框架。SpringCloudStream构建在SpringBoot之上用以创建工业级的应用程序，并且Spring

以你之姓@/ 2022年06月12日 08:29/ 0 赞/ 219 阅读

相关 Spring Boot集成Kafka

系统环境使用远程服务器上搭建的kafka服务 Ubuntu 16.04 LTS kafka\_2.12-0.11.0.0.tgz zookeeper

心已赠人/ 2022年05月28日 07:11/ 0 赞/ 202 阅读

相关 Spring-Boot集成Kafka

这篇文章不讲Kafka相关概念，只是实战。具体了解请参考：《分布式消息中间件实践》《Kafka权威指南》《spring-kafka-reference》spring

迷南。/ 2022年04月22日 07:40/ 0 赞/ 272 阅读

相关 spring cloud Greenwich 学习笔记（十一）spring cloud sleuth集成zipkin + rabbitmq+kafka

欢迎关注本人公众号 ![在这里插入图片描述][20200515113638671.jpg_pic_center] 文章目录欢迎关注本人公众号

柔光的暖阳◎/ 2022年03月17日 07:00/ 0 赞/ 199 阅读

相关 Spring boot 集成Kafka

搭建Kafka集群，参考： [https://www.cnblogs.com/jonban/p/kafka.html][https_www.cnblogs.com_jo

Dear 丶/ 2021年12月14日 12:07/ 0 赞/ 335 阅读

相关 Spring Cloud 集成kafka

pom 依赖 <dependency> <groupId>org.springframework.kafka</groupId>

古城微笑少年丶/ 2021年11月05日 15:22/ 0 赞/ 507 阅读

相关 springboot集成spring-kafka

添加依赖  <dependency> <groupId>org.springf

柔情只为你懂/ 2021年10月19日 10:50/ 0 赞/ 365 阅读