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 執行時 Spring 諮詢 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 Bean 注入到生產者/消費者攔截器
          • 在 Spring 中管理的生產者攔截器
          • 暫停和恢復監聽器容器
          • 暫停和恢復監聽器容器上的分割槽
          • 序列化、反序列化和訊息轉換
          • 訊息頭
          • Null Payload 和“墓碑”記錄的日誌壓縮
          • 處理異常
          • JAAS 和 Kerberos
        • 非阻塞重試
          • 模式如何工作
          • 退避延遲精度
          • 配置
          • 程式設計構造
          • 特性
          • 結合阻塞和非阻塞重試
          • 訪問傳遞嘗試
          • 主題命名
          • 多個監聽器，相同的主題
          • DLT 策略
          • 指定 ListenerContainerFactory
          • 在執行時訪問主題的資訊
          • 更改 KafkaBackOffException 日誌級別
        • Apache Kafka Streams 支援
        • 測試應用程式
      • 提示、技巧和示例
      • 其他資源
      • 覆蓋 Spring Boot 依賴項
      • Micrometer Observation 文件
      • 原生映象
      • 更改歷史
    編輯此頁面 GitHub 專案 Stack Overflow
    • Spring for Apache Kafka
    • 參考
    • 使用 Spring for Apache Kafka
    • 接收訊息
    • 重試訊息傳遞

    重試訊息傳遞

    請參閱 處理異常 中的 DefaultErrorHandler。

    過濾訊息 按順序啟動 @KafkaListeners
    • Spring for Apache Kafka
      • 4.0.0-SNAPSHOT
      • 4.0.0-M2
      • 3.3.6-SNAPSHOT
      • 3.3.5current
      • 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 -博通。 保留所有權利。 術語“博通”是指博通公司和/或其子公司。
    使用條款 • 隱私 • 商標指南 • 謝謝 • 您的加州隱私權 • 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 文件中搜索