Spring
為何選擇 Spring
概述 微服務 響應式 事件驅動 雲 Web 應用 Serverless 批處理
學習
概述 快速入門 指南 部落格
專案
概述 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 安全公告
    社群
    概述 活動 團隊
    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 監聽器容器定製器
            • 定製消費者和生產者配置
            • 定製 AdminClient 配置
            • 定製 Kafka Binder 健康指示器
            • 死信主題處理
            • 死信主題分割槽選擇
            • 使用 Kafka Binder 進行分割槽
          • 響應式 Kafka Binder
            • 概述
            • Maven 座標
            • 使用 Reactive Kafka Binder 的基本示例
            • 消費記錄
            • 併發
            • 多路複用
            • 目標是模式
            • 傳送者結果通道
            • Reactor Kafka Binder 健康指示器
            • Reactive 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 生產者屬性
            • 高階監聽器容器配置
            • 高階配置
            • 接收批處理訊息
            • 釋出者確認
            • 對 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 Pulsar Binder 參考指南

    Spring Cloud Stream Pulsar 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 構建
        • Spring Cloud 匯流排
        • Spring Cloud 斷路器
        • Spring Cloud 通用
        • Spring Cloud 配置
        • Spring Cloud Consul
        • Spring Cloud 合約
        • Spring Cloud 函式
        • Spring Cloud 閘道器
        • Spring Cloud Kubernetes
        • Spring Cloud Netflix
        • Spring Cloud OpenFeign
        • Spring Cloud Stream
        • Spring Cloud 任務
        • Spring Cloud Vault
        • Spring Cloud Zookeeper
      • Spring Data
        • Spring Data Cassandra
        • Spring Data 通用
        • Spring Data Couchbase
        • Spring Data Elasticsearch
        • Spring Data JPA
        • Spring Data 鍵值對
        • 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 是微軟公司的註冊商標。“AWS”和“Amazon Web Services”是 Amazon.com Inc. 或其附屬公司的商標或註冊商標。所有其他商標和版權均為其各自所有者的財產，僅用於提供資訊目的。其他名稱可能是其各自所有者的商標。

    在所有 Spring 文件中搜索