Spring
Ollama文档
Grok文档
OpenAI文档
Pytorch文档
Copilot文档
OpenClaw文档
GeminiAI文档
markdown教程
LangChain开发文档
全部版本
切换语言
中文 English
所有文档
  • 最新文档
  • Spring AI Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security 全部项目
  • 开发工具(英文)
  • Spring.io Spring Tools 4 Spring Initializr
    适用于 Apache Kafka 的 Spring 4.0.5-SNAPSHOT
      • 概述
      • 什么是新内容?
      • 介绍
        • 快速浏览
      • 参考
        • 使用 Spring 为 Apache Kafka
          • 连接到Kafka
          • 配置主题
          • 发送消息
          • 接收消息
            • 消息监听器
            • 消息监听器容器
            • 手动提交偏移量
            • 异步 @KafkaListener 返回类型
            • @KafkaListener 注解
            • 获取 consumer group.id
            • 容器线程命名
            • @KafkaListener 作为元注解
            • @KafkaListener 在类上
            • @KafkaListener 属性修改
            • @KafkaListener 生命周期管理
            • @KafkaListener @Payload 验证
            • 重新平衡监听器
            • 强制消费者重平衡
            • 使用 @SendTo 发送监听器结果
            • 过滤消息
            • 重试投递
            • 开始 @KafkaListeners 在 Sequence 中
            • 使用KafkaTemplate接收
          • 监听器容器属性
          • 动态创建容器
          • 应用程序事件
          • 主题/分区初始偏移
          • 寻找特定偏移
          • 容器工厂
          • 线程安全
          • 监控
          • 事务
          • 精确一次语义
          • 将 Spring Beans 绑定到 Producer/Consumer 拦截器
          • 生产者拦截器在Spring中管理
          • 暂停与恢复监听器容器
          • 暂停并恢复监听器容器中的分区
          • 序列化,反序列化,和消息转换
          • 消息头
          • 空负载与“墓碑”记录的日志压缩
          • 处理异常
          • JAAS 和 Kerberos
          • Kafka 队列(共享消费者)
        • 非阻塞重试
          • 如何工作模式
          • 后退延迟精度
          • 配置
          • 程序化构建
          • 功能
          • 结合阻塞和非阻塞重试
          • 访问配送尝试
          • 主题命名
          • 多个监听器,同一主题(s)
          • DLT 策略
          • 指定监听器容器工厂
          • 运行时访问主题信息
          • 更改 KafkaBackOffException 日志级别
        • Apache Kafka Streams 支持
        • 测试应用程序
      • 提示, 技巧和示例
      • 其他资源
      • 覆盖 Spring Boot 依赖项
      • Micrometer 观测文档
      • 原生镜像
      • 变更历史
    GitHub Project

    这个版本仍在开发中,目前尚未被认为是稳定的。要使用最新稳定版本,请使用 Spring for Apache Kafka 4.0.4!spring-doc.cadn.net.cn

    重试投递

    查看 DefaultErrorHandler 在 处理异常 中的内容。spring-doc.cadn.net.cn

    • Spring for Apache Kafka
    • 参考
    • 使用 Spring 为 Apache Kafka
    • 接收消息
    • 重试投递

    过滤消息 开始 @KafkaListeners 在 Sequence 中
    Spring

    本站点文档内容均由 Spring官网 翻译而来,翻译内容可能存在遗漏或偏差,仅供个人学习,准确内容请以 Spring官网英文文档 为准。
    Copyright © 2005 - 2026 南京筱麦软件有限公司 ( 苏ICP备2022047690号-3 | 苏公网安备32011402011833 )