@KafkaListener注解详解(一)| 常用参数详解

这篇具有很好参考价值的文章主要介绍了@KafkaListener注解详解(一)| 常用参数详解。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

@KafkaListener 注解提供了许多可配置的参数,以便更灵活地定制 Kafka 消息监听器的行为。

topics:

描述: 指定监听的 Kafka 主题,可以是一个字符串数组。这是最基本的参数,它定义了监听器将从哪个或哪些主题接收消息。

例子: @KafkaListener(topics = "my-topic")

groupId:

描述: 指定 Kafka 消费者组的 ID。每个消费者都有自己所属的组。一个组中可以有多个消费者。

例子: @KafkaListener(groupId = "my-group", topics = "my-topic")

id:

描述: 每个Listener实例的重要标识。默认是一个自动生成的唯一 ID。如果不指定groupId,那么id将直接作为groupId。在同一应用中,如果有多个监听器,可以使用不同的id来标识不同的监听器容器。

例子: @KafkaListener(id = "myListener", topics = "my-topic")

concurrency:

描述: 指定并发消费者的数量,即监听器容器的线程数。控制监听器的并发性,每个线程会创建一个消费者实例。较大的并发性可以提高消息处理的吞吐量。

例子: @KafkaListener(topics = "my-topic", concurrency = "3")

containerFactory:

描述: 指定用于创建监听器容器的工厂类。可以用于配置监听器容器的属性。通过设置 containerFactory,可以更灵活地配置监听器容器的一些属性,例如消息转换器、错误处理器等。(移步另外一篇关于工厂类的文章

例子: @KafkaListener(topics = "my-topic", containerFactory = "myContainerFactory")

autoStartup:

描述: 指定是否在启动时自动启动监听器容器。默认是 true。如果设置为false,则需要手动调用容器的start() 方法来启动监听器。(移步另外一篇关于改变kafka运行状态的文章

例子: @KafkaListener(topics = "my-topic", autoStartup = "false")

clientIdPrefix:

描述: 指定 Kafka 消费者的客户端 ID 前缀。可以通过设置clientIdPrefix来自定义消费者的客户端 ID。

例子: @KafkaListener(topics = "my-topic", clientIdPrefix = "my-client")

containerGroup:

描述: 指定监听器容器所属的组。如果有多个应用使用相同的消费者组,可以通过设置 containerGroup来区分它们。

例子: @KafkaListener(topics = "my-topic", containerGroup = "my-group")

errorHandler:

描述: 指定错误处理器,用于处理监听器方法抛出的异常。定义一个错误处理器,可以在发生异常时进行自定义处理。

例子: @KafkaListener(topics = "my-topic", errorHandler = "myErrorHandler")

properties:

描述: 指定其他的消费者配置属性,以键值对的形式提供。这种方式允许你通过注解的方式灵活地设置特定的消费者属性,而不必在全局配置文件中进行设置。请确保设置的属性是合法的 Kafka 消费者属性,并符合你的应用需求。

例子: @KafkaListener(topics = "my-topic", properties = {"enable.auto.commit=false", "auto.offset.reset=earliest"})


这些参数可以根据实际需求进行组合和配置,以满足特定场景的要求。例如,通过调整 concurrency 可以控制监听器的并发性,通过设置 autoStartup 可以控制监听器容器是否在应用启动时自动启动。其他参数也可以根据需要进行调整。

DEMO

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void listen(ConsumerRecord<String, String> record) {
        System.out.println("Received message: " + record.value());
    }
}

关于ConsumerRecord<?, ?> record的介绍参考:url

@KafkaListener注解应用于listen方法,指定要监听的Kafka主题和消费者组ID。

在application.properties中配置Kafka连接信息:

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group

关于kafka在application.properties配置参数的介绍参考:url文章来源地址https://www.toymoban.com/news/detail-760248.html

到了这里,关于@KafkaListener注解详解(一)| 常用参数详解的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 工具篇--4.1RabbitMq--常用配置参数详解

    前言: 在使用Rabbitmq 过程中,每次配置参数都需要进行搜索和回忆,本文对rabbitmq 中常用的配置成参数进行列举并解释; 这里先粘下比较常用的参数及其简单注注释,更为详细的注释可以在文章中后面的部分进行解读: 参数分类介绍: 1 基础参数: 客户端连接mq 服务端必要

    2024年02月12日
    浏览(45)
  • Kafka中的max-poll-records和listener.concurrency配置

    1、max-poll-records是什么 max-poll-records 是Kafka consumer的一个配置参数,表示consumer一次从Kafka broker中拉取的最大消息数目,默认值为 500 条。在Kafka中,一个消费者组可以有多个consumer实例,每个consumer实例负责消费一个或多个partition的消息,每个consumer实例一次从broker中可以拉取一

    2024年01月17日
    浏览(77)
  • @KafkaListener指定kafka集群

    基于@KafkaListener注解的kafka监听代码可以手动指定要消费的kafka集群,这对于需要访问多套kafka集群的程序来说,是有效的解决方案。这里需要注意的是,此时的消费者配置信息需使用原生kafka的配置信息格式(如:ConsumerConfig.MAX_POLL_RECORDS_CONFIG = “max.poll.records”),与自动装载

    2024年01月21日
    浏览(55)
  • Springboot常用方法参数注解及示例

    Springboot常用方法参数注解及示例 一、 @RequestParam : 从URL查询参数中提取数据。 二、 @PathVariable : 从URL路径中提取数据。 三、 @RequestBody : 从请求体中提取数据,并映射到对象。 四、 @RequestHeader : 从请求头中提取数据。 五、 @Validated / @Valid : 启用方法参数校验,确保参

    2024年02月10日
    浏览(40)
  • SpringMVC常用注解、参数传递、返回值

    目录 前言 一、常用注解 二、参数传递 ​编辑 1. 基础类型+String类型 2. 复杂类型 3. @RequestParam 4. @PathVariable  5.@RequestBody 6. @RequestHeader  三、方法返回值 一:void 二:String 三:String+model  四:ModelAndView  四、页面跳转 在上一篇的博客中我们初步的了解学习SpringMVC基础知识,

    2024年02月09日
    浏览(35)
  • Spring Boot请求处理-常用参数注解

    @PathVariable 路径变量 @RequestParam 获取请求参数 @RequestHeader 获取请求头 @RequestBody 获取请求体【Post】 @CookieValue 获取Cookie值 RequestAttribute 获取request域属性 @ModelAttribute 1. @PathVariable 该注解主要用于rest风格的搭配使用,请求路径中不再以 k:v 的形式给出请求参数和值;而是直接给定

    2024年02月10日
    浏览(52)
  • kafka @KafkaListener 动态接收topic

    @KafkaListener 里边的 topics 必须是常量,不可以是变量 但是某些业务场景 kafka定义的topic会不同这时候就需要传入变量才可以实现 具体实现方式如下: KafkaListener 监听方法 #{}  这里边是方法名称  这里是获取topic 其实可以在对应的@Bean里边写逻辑方法去处理 这里用到了获取配

    2024年02月13日
    浏览(38)
  • Spring MVC:常用参数(注解)的使用和参数绑定的验证

    Java EE企业级应用开发教程(Spring+Spring MVC+MyBatis)(第2版) Spring MVC常用参数 Spring MVC简单应用 Spring MVC参数绑定 本实验采用的是本地安装的tomcat8.5.0版本 (1)创建maven 管理的java web工程 (2)添加本地tomcat war包 (3)实验过程 输出Hello Word 访问端口:http://localhost:8080/chapter1

    2024年02月04日
    浏览(42)
  • springboot kafka消息消费学习 @KafkaListener 使用

    kafka 配置类 用途:定义使用的基本 kafka 配置,以及定义Bean 下面文件是读取本地 spring 的标准配置文件的类,用于一般属性获取等操作 @Data 为其他用于控制get set 方法的,与 此处配置不是强关联,可以没有 实际 kafka 监听消费 @ConditionalOnProperty spring boot 用于判断当前类是否加

    2024年02月08日
    浏览(39)
  • SpringMVC的常用注解,参数传递以及页面跳转的使用

    目录 slf4j 常用注解 @RequestMapping @RequestParam @RequestBody @PathVariable 参数传递  首先在pom.xml配置文件中导入SLF4J的依赖 基础类型+String   复杂类型 @RequestParam @PathVariable @RequestBody  增删改查  返回值 void返回值  String返回值 model+String   页面跳转 --转发和重定向 SLF4J,简单日志门面

    2024年02月09日
    浏览(41)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包