Spring
为什么选择 Spring
概览 微服务 响应式 事件驱动 云 Web 应用 无服务器 批处理
学习
概览 快速入门 指南 博客
项目
概览 Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security 查看所有项目
  • 开发工具
  • Spring Tools 4 Spring Initializr
    学院
    课程 获取认证
    解决方案
    概览 Spring Runtime Spring Consulting Spring Academy For Teams 安全公告
    社区
    概览 活动 团队
    Spring for Apache Kafka 3.3.5
      • 概览
      • 最新动态?
      • 简介
        • 快速浏览
      • 参考文档
        • 使用 Spring for Apache Kafka
          • 连接到 Kafka
          • 配置 Topic
          • 发送消息
          • 接收消息
            • 消息监听器
            • 消息监听器容器
            • 手动提交 Offset
            • 异步 @KafkaListener 返回类型
            • @KafkaListener 注解
            • 获取 Consumer group.id
            • 容器线程命名
            • 将 @KafkaListener 作为元注解
            • 类上的 @KafkaListener
            • @KafkaListener 属性修改
            • @KafkaListener 生命周期管理
            • @KafkaListener @Payload 验证
            • 重平衡监听器
            • 强制 Consumer 重平衡
            • 使用 @SendTo 转发监听器结果
            • 过滤消息
            • 重试发送
            • 按顺序启动 @KafkaListener
            • 使用 KafkaTemplate 接收
          • 监听器容器属性
          • 动态创建容器
          • 应用程序事件
          • Topic/分区 初始 Offset
          • 查找特定 Offset
          • 容器工厂
          • 线程安全
          • 监控
          • 事务
          • 精确一次语义
          • 将 Spring Beans 注入 Producer/Consumer Interceptor
          • 在 Spring 中管理的 Producer Interceptor
          • 暂停和恢复监听器容器
          • 暂停和恢复监听器容器上的分区
          • 序列化、反序列化和消息转换
          • 消息头
          • Null Payloads 和 'Tombstone' 记录的日志压缩
          • 异常处理
          • JAAS and Kerberos
        • 非阻塞重试
          • 模式工作原理
          • 回退延迟精度
          • 配置
          • 编程构建
          • 特性
          • 结合阻塞和非阻塞重试
          • 访问发送尝试次数
          • Topic 命名
          • 多个监听器,相同 Topic(s)
          • DLT 策略
          • 指定 ListenerContainerFactory
          • 运行时访问 Topic 信息
          • 更改 KafkaBackOffException 日志级别
        • Apache Kafka Streams 支持
        • 测试应用程序
      • 技巧、诀窍和示例
      • 其他资源
      • 覆盖 Spring Boot 依赖
      • Micrometer Observation 文档
      • Native Images
      • 变更历史

    Spring 项目

    • Spring Boot
    • Spring Framework
    • Spring Cloud
      • Spring Cloud Build
      • Spring Cloud Bus
      • Spring Cloud Circuit Breaker
      • Spring Cloud Commons
      • Spring Cloud Config
      • Spring Cloud Consul
      • Spring Cloud Contract
      • Spring Cloud Function
      • Spring Cloud Gateway
      • Spring Cloud Kubernetes
      • Spring Cloud Netflix
      • Spring Cloud OpenFeign
      • Spring Cloud Stream
      • Spring Cloud Task
      • Spring Cloud Vault
      • Spring Cloud Zookeeper
    • Spring Data
      • Spring Data Cassandra
      • Spring Data Commons
      • Spring Data Couchbase
      • Spring Data Elasticsearch
      • Spring Data JPA
      • Spring Data KeyValue
      • Spring Data LDAP
      • Spring Data MongoDB
      • Spring Data Neo4j
      • Spring Data Redis
      • Spring Data JDBC & R2DBC
      • Spring Data REST
    • Spring Integration
    • Spring Batch
    • Spring Security
      • Spring Authorization Server
      • Spring LDAP
      • Spring Security Kerberos
      • Spring Session
      • Spring Vault
    • Spring AI
    • Spring AMQP
    • Spring CLI
    • Spring GraphQL
    • Spring for Apache Kafka
    • Spring Modulith
    • Spring for Apache Pulsar
    • Spring Shell
    • Spring for Apache Kafka
      • 4.0.0-SNAPSHOT
      • 4.0.0-M2
      • 3.3.6-SNAPSHOT
      • 3.3.5当前
      • 3.2.9-SNAPSHOT
      • 3.2.8
      • 3.1.11-SNAPSHOT
      • 3.1.10
    • 相关 Spring 文档
      • Spring Boot
      • Spring Framework
      • Spring Cloud
        • Spring Cloud Build
        • Spring Cloud Bus
        • Spring Cloud Circuit Breaker
        • Spring Cloud Commons
        • Spring Cloud Config
        • Spring Cloud Consul
        • Spring Cloud Contract
        • Spring Cloud Function
        • Spring Cloud Gateway
        • Spring Cloud Kubernetes
        • Spring Cloud Netflix
        • Spring Cloud OpenFeign
        • Spring Cloud Stream
        • Spring Cloud Task
        • Spring Cloud Vault
        • Spring Cloud Zookeeper
      • Spring Data
        • Spring Data Cassandra
        • Spring Data Commons
        • Spring Data Couchbase
        • Spring Data Elasticsearch
        • Spring Data JPA
        • Spring Data KeyValue
        • Spring Data LDAP
        • Spring Data MongoDB
        • Spring Data Neo4j
        • Spring Data Redis
        • Spring Data JDBC & R2DBC
        • Spring Data REST
      • Spring Integration
      • Spring Batch
      • Spring Security
        • Spring Authorization Server
        • Spring LDAP
        • Spring Security Kerberos
        • Spring Session
        • Spring Vault
      • Spring AI
      • Spring AMQP
      • Spring CLI
      • Spring GraphQL
      • Spring for Apache Kafka
      • Spring Modulith
      • Spring for Apache Pulsar
      • Spring Shell
    • 所有文档...
    Spring

    Copyright © 2005 -Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
    使用条款 • 隐私 • 商标指南 • 谢谢 • 您的加州隐私权 • Cookie 设置

    Apache®, Apache Tomcat®, Apache Kafka®, Apache Cassandra™, and Apache Geode™ are trademarks or registered trademarks of the Apache Software Foundation in the United States and/or other countries. Java™, Java™ SE, Java™ EE, and OpenJDK™ are trademarks of Oracle and/or its affiliates. Kubernetes® is a registered trademark of the Linux Foundation in the United States and other countries. Linux® is the registered trademark of Linus Torvalds in the United States and other countries. Windows® and Microsoft® Azure are registered trademarks of Microsoft Corporation. “AWS” and “Amazon Web Services” are trademarks or registered trademarks of Amazon.com Inc. or its affiliates. All other trademarks and copyrights are property of their respective owners and are only mentioned for informative purposes. Other names may be trademarks of their respective owners.

    在所有 Spring 文档中搜索