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
          • 繫結 (Bindings)
          • 繫結 (Binding) 和繫結名稱
          • 函式式繫結名稱
          • 顯式建立繫結
          • 繫結視覺化和控制
          • 生產和消費訊息
          • 事件路由
          • 後處理 (傳送訊息後)
        • Binder 抽象
          • 可插拔的 Binder SPI
          • Binder 檢測
          • Classpath 上的多個 Binder
          • 連線到多個系統
          • 在多 Binder 應用中定製 Binder
        • 錯誤處理
        • 可觀測性
        • 配置選項
          • 繫結服務屬性
          • 繫結屬性
        • 內容型別協商
          • 機制
          • 提供的 MessageConverter
          • 使用者自定義 MessageConverter
        • 應用間通訊
          • 連線多個應用例項
          • 例項索引和例項數量
        • 分割槽
        • 測試
        • 健康指示器
        • 示例
      • Binder
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概覽
            • 配置選項
            • 重置偏移量
            • 消費批次
            • 手動確認
            • 安全配置
            • 暫停和恢復消費者
            • 事務性 Binder
            • 錯誤通道
            • Kafka 指標
            • 墓碑記錄 (Tombstone Records)
            • KafkaBindingRebalanceListener
            • 重試和死信處理
            • Kafka Binder Listener Container 定製器
            • 定製消費者和生產者配置
            • 定製 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 Processor
            • 選擇性手動啟動 Kafka Streams Processor
            • 使用 Spring Cloud Sleuth 進行跟蹤
            • 配置選項
          • 提示和技巧
            • 提示、技巧和妙招
        • RabbitMQ Binder 參考指南
          • 配置選項
            • RabbitMQ Binder 屬性
            • RabbitMQ 消費者屬性
            • RabbitMQ 生產者屬性
            • 高階 Listener Container 配置
            • 高階配置
            • 接收批處理訊息
            • 釋出者確認
            • 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

    搜尋

    • 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 Inc. 和/或其子公司。
    使用條款 • 隱私 • 商標指南 • 致謝 • 您的加州隱私權利 • Cookie 設定

    Apache®、Apache Tomcat®、Apache Kafka®、Apache Cassandra™ 和 Apache Geode™ 是 Apache 軟體基金會(Apache Software Foundation)在美國和/或其他國家的商標或註冊商標。Java™、Java™ SE、Java™ EE 和 OpenJDK™ 是 Oracle 和/或其關聯公司的商標。Kubernetes® 是 Linux 基金會(The Linux Foundation)在美國及其他國家的註冊商標。Linux® 是 Linus Torvalds 在美國及其他國家的註冊商標。Windows® 和 Microsoft® Azure 是微軟公司(Microsoft Corporation)的註冊商標。“AWS” 和 “Amazon Web Services” 是 Amazon.com Inc. 或其關聯公司的商標或註冊商標。所有其他商標和版權均為其各自所有者的財產,僅為提供資訊之目的而提及。其他名稱可能是其各自所有者的商標。

    在所有 Spring 文件中搜索