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-cloud-stream 4.2.1
      • Spring 数据集成发展简史
      • 简介
      • Spring Cloud Stream 参考文档
        • 主要概念和抽象
          • Spring Cloud Stream 的应用模型
          • Binder 抽象
          • 持久化发布-订阅支持
          • 消费者组支持
          • 分区支持
        • 编程模型
          • 目标 Binder
          • 绑定
          • 绑定和绑定名称
          • 函数式绑定名称
          • 显式绑定创建
          • 绑定可视化与控制
          • 生产和消费消息
          • 事件路由
          • 后处理 (发送消息后)
        • Binder 抽象
          • 可插拔的 Binder SPI
          • Binder 检测
          • 类路径中的多个 Binder
          • 连接到多个系统
          • 多 Binder 应用中的 Binder 定制
        • 错误处理
        • 可观测性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机制
          • 提供的消息转换器
          • 用户自定义消息转换器
        • 应用间通信
          • 连接多个应用实例
          • 实例索引和实例计数
        • 分区
        • 测试
        • 健康指示器
        • 示例
      • Binders
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概览
            • 配置选项
            • 重置偏移量
            • 批量消费
            • 手动确认
            • 安全配置
            • 暂停和恢复消费者
            • 事务性 Binder
            • 错误通道
            • Kafka 指标
            • 墓碑记录
            • KafkaBindingRebalanceListener
            • 重试和死信处理
            • Kafka Binder 监听容器定制器
            • 定制消费者和生产者配置
            • 定制 AdminClient 配置
            • 定制 Kafka Binder 健康指示器
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka Binder 进行分区
          • Reactive Kafka Binder
            • 概览
            • Maven 坐标
            • 使用 Reactive Kafka Binder 的基本示例
            • 消费记录
            • 并发
            • 复用
            • 目标是模式
            • 发送者结果通道
            • Reactor Kafka Binder 健康指示器
            • Reactive Kafka Binder 中的可观测性
          • Kafka Streams 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 生产者属性
            • 高级监听容器配置
            • 高级配置
            • 接收批量消息
            • 发布者确认
            • RabbitMQ Stream Plugin 的初始消费者支持
            • RabbitMQ Stream Plugin 的初始生产者支持
          • 使用现有队列/交换机
          • 使用 RabbitMQ Binder 进行重试
            • 整合所有内容
          • 错误通道
          • 使用 RabbitMQ Binder 进行分区
          • Rabbit Binder 健康指示器
        • Apache Pulsar
          • Spring Cloud Stream Binder for Apache Pulsar
        • Solace
        • Amazon Kinesis
      • Spring Cloud Stream Schema Registry

    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-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

    版权所有 © 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 是微软公司(Microsoft Corporation)的注册商标。"AWS" 和 "Amazon Web Services" 是 Amazon.com Inc. 或其关联公司的商标或注册商标。所有其他商标和版权为其各自所有者的财产,仅用于提供信息。其他名称可能是其各自所有者的商标。

    在所有 Spring 文档中搜索