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 咨询 Spring 团队学院 安全公告
    社区
    概述 活动 团队
    spring-cloud-stream 4.2.1
      • Spring 数据集成之旅简史
      • 引言
      • Spring Cloud Stream 参考文档
        • 主要概念与抽象
          • Spring Cloud Stream 的应用模型
          • Binder 抽象
          • 持久化发布-订阅支持
          • 消费者组支持
          • 分区支持
        • 编程模型
          • 目标 Binder
          • 绑定
          • 绑定与绑定名称
          • 函数式绑定名称
          • 显式绑定创建
          • 绑定可视化与控制
          • 消息生产与消费
          • 事件路由
          • 后处理（消息发送后）
        • Binder 抽象
          • 可插拔的 Binder SPI
          • Binder 检测
          • Classpath 上的多个 Binder
          • 连接多个系统
          • 在多 Binder 应用中自定义 Binder
        • 错误处理
        • 可观测性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机制
          • 提供的 MessageConverter
          • 用户定义的 Message Converter
        • 应用间通信
          • 连接多个应用实例
          • 实例索引与实例数量
        • 分区
        • 测试
        • 健康指示器
        • 示例
      • Binder
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 批量消费
            • 手动确认
            • 安全配置
            • 暂停和恢复消费者
            • 事务性 Binder
            • 错误通道
            • Kafka 指标
            • 墓碑记录
            • KafkaBindingRebalanceListener
            • 重试与死信处理
            • Kafka Binder Listener 容器自定义器
            • 自定义消费者和生产者配置
            • 自定义 AdminClient 配置
            • 自定义 Kafka Binder 健康指示器
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka Binder 进行分区
          • 响应式 Kafka Binder
            • 概述
            • Maven 坐标
            • 使用响应式 Kafka Binder 的基本示例
            • 消费记录
            • 并发
            • 多路复用
            • 目标为模式
            • 发送者结果通道
            • Reactor Kafka Binder 健康指示器
            • 响应式 Kafka Binder 中的可观测性
          • Kafka Stream Binder
            • 用法
            • 概述
            • 编程模型
            • 编程模型的辅助功能
            • 记录序列化与反序列化
            • 错误处理
            • 重试关键业务逻辑
            • 状态存储
            • 交互式查询
            • 健康指示器
            • 访问 Kafka Streams 指标
            • 混合使用高级 DSL 和低级 Processor API
            • 出站分区支持
            • StreamsBuilderFactoryBean 配置器
            • 时间戳提取器
            • 带有基于 Kafka Streams Binder 和常规 Kafka Binder 的多 Binder
            • 状态清理
            • Kafka Streams 拓扑可视化
            • Kafka Streams 应用中基于事件类型的路由
            • Kafka Streams Binder 中的绑定可视化与控制
            • 手动启动 Kafka Streams 处理器
            • 选择性手动启动 Kafka Streams 处理器
            • 使用 Spring Cloud Sleuth 进行追踪
            • 配置选项
          • 提示与秘籍
            • 提示、技巧与秘籍
        • RabbitMQ Binder 参考指南
          • 配置选项
            • RabbitMQ Binder 属性
            • RabbitMQ 消费者属性
            • RabbitMQ 生产者属性
            • 高级 Listener 容器配置
            • 高级配置
            • 接收批量消息
            • 发布者确认
            • RabbitMQ Stream 插件的初始消费者支持
            • RabbitMQ Stream 插件的初始生产者支持
          • 使用现有队列/交换机
          • 使用 RabbitMQ Binder 进行重试
            • 整合所有内容
          • 错误通道
          • 使用 RabbitMQ Binder 进行分区
          • Rabbit Binder 健康指示器
        • Apache Pulsar
          • Spring Cloud Stream 的 Apache Pulsar Binder
        • Solace
        • Amazon Kinesis
      • Spring Cloud Stream Schema Registry
    编辑此页 GitHub 项目 Stack Overflow
    • spring-cloud-stream
    • Spring Cloud Stream RabbitMQ Binder 参考指南

    Spring Cloud Stream RabbitMQ Binder 参考指南

    参考指南

    • spring-cloud-stream
      • 4.3.0-SNAPSHOT
      • 4.3.0-RC1
      • 4.2.1当前
      • 4.1.6-SNAPSHOT
      • 4.1.5
    • 相关 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. 保留所有权利。术语“Broadcom”指代 Broadcom Inc. 和/或其子公司。
    使用条款 • 隐私政策 • 商标指南 • 感谢 • 您的加州隐私权利 • Cookie 设置

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

    在所有 Spring 文档中搜索