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 註解
            • 獲取 Consumer group.id
            • 容器執行緒命名
            • 作為元註解的 @KafkaListener
            • 類上的 @KafkaListener
            • @KafkaListener 屬性修改
            • @KafkaListener 生命週期管理
            • @KafkaListener @Payload 驗證
            • 重新平衡監聽器
            • 強制 Consumer 重新平衡
            • 使用 @SendTo 轉發監聽器結果
            • 過濾訊息
            • 重試交付
            • 按順序啟動 @KafkaListener
            • 使用 KafkaTemplate 接收
          • 監聽器容器屬性
          • 動態建立容器
          • 應用程式事件
          • 主題/分割槽初始偏移量
          • Seek 到特定偏移量
          • 容器工廠
          • 執行緒安全
          • 監控
          • 事務
          • 精確一次語義
          • 將 Spring Beans 注入到 Producer/Consumer 攔截器
          • 在 Spring 中管理的 Producer 攔截器
          • 暫停和恢復監聽器容器
          • 暫停和恢復監聽器容器上的分割槽
          • 序列化、反序列化和訊息轉換
          • 訊息頭
          • Null Payload 和 'Tombstone' 記錄的日誌壓縮
          • 處理異常
          • JAAS 和 Kerberos
        • 非阻塞重試
          • 模式如何工作
          • Back Off 延遲精度
          • 配置
          • 以程式設計方式構建
          • 功能
          • 組合阻塞和非阻塞重試
          • 訪問交付嘗試
          • 主題命名
          • 多個監聽器,相同主題
          • DLT 策略
          • 指定 ListenerContainerFactory
          • 在執行時訪問主題的資訊
          • 更改 KafkaBackOffException 日誌級別
        • Apache Kafka Streams 支援
        • 測試應用程式
      • 提示、技巧和示例
      • 其他資源
      • 覆蓋 Spring Boot 依賴
      • Micrometer Observation 文件
      • 原生映象
      • 變更歷史
    編輯此頁面 GitHub 專案 Stack Overflow
    • Spring for Apache Kafka
    • 原生映象

    原生映象

    提供了 Spring AOT 原生提示,以協助開發使用 Spring for Apache Kafka 的 Spring 應用程式的本機映象,包括用於 @KafkaListener 的 AVRO 生成類的提示。

    原生映象不支援 spring-kafka-test (特別是其 EmbeddedKafkaBroker)。

    一些示例可以在 spring-aot-smoke-tests GitHub 儲存庫中看到。

    Micrometer Observation 文件 變更歷史
    • 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 -Broadcom。 保留所有權利。“Broadcom”一詞是指 Broadcom Inc. 和/或其子公司。
    使用條款 • 隱私 • 商標指南 • 謝謝 • 您的加州隱私權 • 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 文件中搜索