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
          • 配置主题
          • 发送消息
          • 接收消息
            • 消息监听器
            • 消息监听器容器
            • 手动提交偏移量
            • 异步 @KafkaListener 返回类型
            • @KafkaListener 注解
            • 获取消费者 group.id
            • 容器线程命名
            • @KafkaListener 作为元注解
            • 类上的 @KafkaListener
            • @KafkaListener 属性修改
            • @KafkaListener 生命周期管理
            • @KafkaListener @Payload 验证
            • 重平衡监听器
            • 强制消费者重平衡
            • 使用 @SendTo 转发监听器结果
            • 消息过滤
            • 重试投递
            • 按顺序启动 @KafkaListener
            • 使用 KafkaTemplate 接收
          • 监听器容器属性
          • 动态创建容器
          • 应用事件
          • 主题/分区的初始偏移量
          • 跳转到特定偏移量
          • 容器工厂
          • 线程安全
          • 监控
          • 事务
          • 精确一次语义
          • 将 Spring Beans 注入生产者/消费者拦截器
          • Spring 管理的生产者拦截器
          • 暂停和恢复监听器容器
          • 暂停和恢复监听器容器上的分区
          • 序列化、反序列化和消息转换
          • 消息头
          • Null 负载和 'Tombstone' 记录的日志压缩
          • 异常处理
          • JAAS 和 Kerberos
        • 非阻塞重试
          • 模式工作原理
          • 退避延迟精度
          • 配置
          • 编程式构建
          • 特性
          • 组合使用阻塞和非阻塞重试
          • 访问投递尝试次数
          • 主题命名
          • 多个监听器监听同一主题
          • DLT 策略
          • 指定 ListenerContainerFactory
          • 运行时访问主题信息
          • 修改 KafkaBackOffException 日志级别
        • Apache Kafka Streams 支持
        • 测试应用
      • 提示、技巧和示例
      • 其他资源
      • 覆盖 Spring Boot 依赖
      • Micrometer Observation 文档
      • Native Images
      • 变更历史
    编辑此页面 GitHub 项目 Stack Overflow
    • Spring for Apache Kafka
    • 参考
    • 使用 Spring for Apache Kafka
    • 接收消息

    接收消息

    可以通过配置 MessageListenerContainer 并提供消息监听器来接收消息,或者使用 @KafkaListener 注解。

    本节概要

    • 消息监听器
    • 消息监听器容器
    • 手动提交偏移量
    • 异步 @KafkaListener 返回类型
    • @KafkaListener 注解
    • 获取消费者 group.id
    • 容器线程命名
    • @KafkaListener 作为元注解
    • 类上的 @KafkaListener
    • @KafkaListener 属性修改
    • @KafkaListener 生命周期管理
    • @KafkaListener @Payload 验证
    • 重平衡监听器
    • 强制消费者重平衡
    • 使用 @SendTo 转发监听器结果
    • 消息过滤
    • 重试投递
    • 按顺序启动 @KafkaListener
    • 使用 KafkaTemplate 接收
    发送消息 消息监听器
    • 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

    版权所有 © 2005 -Broadcom. 保留所有权利。术语 "Broadcom" 指 Broadcom Inc. 和/或其子公司。
    使用条款 • 隐私权政策 • 商标指南 • 感谢 • 您的加州隐私权 • Cookie 设置

    Apache®、Apache Tomcat®、Apache Kafka®、Apache Cassandra™ 和 Apache Geode™ 是 Apache Software Foundation 在美国和/或其他国家/地区的商标或注册商标。Java™、Java™ SE、Java™ EE 和 OpenJDK™ 是 Oracle 和/或其关联公司的商标。Kubernetes® 是 Linux Foundation 在美国和其他国家/地区的注册商标。Linux® 是 Linus Torvalds 在美国和其他国家/地区的注册商标。Windows® 和 Microsoft® Azure 是 Microsoft Corporation 的注册商标。“AWS”和“Amazon Web Services”是 Amazon.com Inc. 或其关联公司的商标或注册商标。所有其他商标和版权均为其各自所有者的财产,仅用于信息目的。其他名称可能是其各自所有者的商标。

    在所有 Spring 文档中搜索