首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

如果设置spring.kafka.listener.ack-mode=time,是否会重试?或者在指定的ack-mode中重试工作?

在Spring Kafka中,如果设置了spring.kafka.listener.ack-mode=time,不会自动重试。

spring.kafka.listener.ack-mode属性用于指定监听器的应答模式,它有以下几种取值:

  1. record:在接收到消息后立即发送确认。这是最常见的模式,用于大多数情况。
  2. batch:在接收到一批消息后发送确认。通常与spring.kafka.listener.ack-mode属性AckMode.RECORD配合使用,以便在消费一批消息后发送确认。
  3. time:在接收到消息后,等待一段时间后发送确认。这个时间由spring.kafka.listener.ack-time属性指定,默认为5000毫秒(即5秒)。
  4. count:在接收到一定数量的消息后发送确认。这个数量由spring.kafka.listener.ack-count属性指定,默认为1。

上述的四种应答模式都不会自动进行重试。如果需要进行重试,可以通过其他机制实现,例如使用@Retryable注解或者自定义异常处理器来捕获并重试处理失败的消息。

对于Kafka相关的产品和产品介绍,推荐使用腾讯云的消息队列 CKafka(https://cloud.tencent.com/product/ckafka)作为推荐的产品。它是一个高性能、可靠、可弹性扩展的分布式消息队列服务,支持大规模消息集群的分布式消息传递,并具备高并发、高可用、可靠消息投递的特点。在使用消息队列 CKafka时,可以根据具体需求选择合适的应答模式来满足业务需求。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

  • 什么是Spring Boot

    logging.config= # Location of the logging configuration file. For instance classpath:logback.xml for Logback logging.exception-conversion-word=%wEx # Conversion word used when logging exceptions. logging.file= # Log file name. For instance myapp.log logging.level.*= # Log levels severity mapping. For instance logging.level.org.springframework=DEBUG logging.path= # Location of the log file. For instance /var/log logging.pattern.console= # Appender pattern for output to the console. Only supported with the default logback setup. logging.pattern.file= # Appender pattern for output to the file. Only supported with the default logback setup. logging.pattern.level= # Appender pattern for log level (default %5p). Only supported with the default logback setup. logging.register-shutdown-hook=false # Register a shutdown hook for the logging system when it is initialized.

    05
    领券