首页 > 其他分享 >Kafka的注解KafkaListener,属性:containerFactory

Kafka的注解KafkaListener,属性:containerFactory

时间:2023-02-17 20:34:04浏览次数:32  
标签:spring KafkaListener kafka containerFactory https Kafka

 kafka的2个topic,如果2个 ConsumerConfig配置不一样。

@KafkaListener(id = "${groupId}", topics={"TOPIC"}, containerFactory = "DefinekafkaListenerContainerFactory")

如果不配置 containerFactory,那么默认的是用 kafkaListenerContainerFactory。如果需要自定义,可以在 containerFactory设置。

 

参考链接:

https://docs.spring.io/spring-kafka/reference/html/#message-listener-container

https://stackoverflow.com/questions/62633041/how-does-default-kafkalistenercontainerfactory-work

标签:spring,KafkaListener,kafka,containerFactory,https,Kafka
From: https://www.cnblogs.com/parkdifferent/p/17131428.html

相关文章

  • springboot接入kafka
    1、windows下安装、启动kafka,这一步只是搭建环境​​https://blog.51cto.com/u_15595167/6026035​​2、安装kafka管理工具:kafkamanager,推荐linux下安装,windows下编译等很麻......
  • kafka单节点安装
    下载地址:https://archive.apache.org/dist/kafka/2.2.2/kafka_2.11-2.2.2.tgz 1.配置server.xml#对外监听地址listeners=PLAINTEXT://172.17.68.115:9092......
  • kafka日志数据清理策略
    vim/kafka/server.properties #日志清理策略优先级是谁先满足条件.#保留7天的日志数据log.retention.hours=168#日志数据总大小保留100G,默认-1无穷大log.retenti......
  • 部署canal同步mysql-binlog到kafka具体操作
    准备[mysqld]log-bin=mysql-bin#开启binlogbinlog-format=ROW#选择ROW模式授权canal链接MySQL账号具有作为MySQLslave的权限CREATEUSERcanalIDENTI......
  • dinky-binlog-kafka-flinksql流程处理
    准确阶段:mysql:开启mysql日志kafka:需检查服务是否正常maxwell:这里采用19版本,过新的版本对java版本要求高,我这里是java8maxwell-1.19.0maxwell操作:cd/root/tar_temp/maxwell-......
  • kafka
    1、名词介绍broker:一台kafka服务器就是一个brokerPartition:是实际存储消息的物理单元,一个Topic内部可以包含多个partition。Topic内部的partition是从0开始,顺序编号,消息......
  • 【Spring-boot-route(十四)整合Kafka】
    kafka简介kafka是用Scala和Java语言开发的,高吞吐量的分布式消息中间件。高吞吐量使它在大数据领域具有天然的优势,被广泛用来记录日志。kafka架构分析注1:图中的红色箭头表示......
  • 决战圣地玛丽乔亚Day10--kafka学习
    概念上kafka和RocketMQ的结构很类似。除了Broker、Producer、Consumer、Topic。多了一个分区的概念Partition。对于NameServer的概念,kafka用的是zookeeper来保存信息。包......
  • 通过 KoP 将 Kafka 应用迁移到 Pulsar
    通过KoP将Kafka应用迁移到Pulsar版权声明:原文出自https://github.com/streamnative/kop,由Redisant进行整理和翻译目录通过KoP将Kafka应用迁移到Pulsar什......
  • Kafka原理-分区leader选举
    0.说明kafka源码版本为1.0 1.分区状态kafka源码定义了4种状态NewPartition:表示正在创建新的分区,是一个中间状态,只是在Controller的内存中存了状态信息OnlinePart......