使用 Spring for Apache Kafka

本節摘要

• 連線到 Kafka
• 配置主題
• 傳送訊息
• 接收訊息
• 監聽器容器屬性
• 動態建立容器
• 應用事件
• 主題/分割槽初始偏移量
• 查詢特定偏移量
• 容器工廠
• 執行緒安全
• 監控
• 事務
• 精確一次語義
• 將 Spring Beans 注入生產者/消費者攔截器
• 在 Spring 中管理的生產者攔截器
• 暫停和恢復監聽器容器
• 暫停和恢復監聽器容器上的分割槽
• 序列化、反序列化和訊息轉換
• 訊息頭
• 空 Payload 和 'Tombstone' 記錄的日誌壓縮
• 異常處理
• JAAS 和 Kerberos