Spring
AI
Spring AI
Java
Quarkus Spring Spring Data Spring Cloud Hibernate
Python
Database
Postgresql Mysql
Spring Cloud Stream 中文文档 4.3.0
    • Spring 数据集成之旅的简史
    • 简介
    • Spring Cloud Stream 参考文档
      • 主要概念和抽象
        • Spring Cloud Stream 的应用模型
        • 绑定器抽象
        • 持久化发布-订阅支持
        • 消费者组支持
        • 分区支持
      • 编程模型
        • 目标绑定器
        • 绑定
        • 绑定和绑定名称
        • 函数式绑定名称
        • 显式绑定创建
        • 绑定可视化和控制
        • 生产和消费消息
        • 事件路由
        • 后处理（发送消息之后）
      • 绑定器抽象
        • 可插拔的绑定器 SPI
        • 绑定器检测
        • 类路径上的多个绑定器
        • 连接到多个系统
        • 在多绑定器应用中自定义绑定器
      • 错误处理
      • 可观测性
      • 配置选项
        • 绑定服务属性
        • 绑定属性
      • 内容类型协商
        • 机制
        • 提供的 MessageConverter
        • 用户定义的消息转换器
      • 应用间通信
        • 连接多个应用程序实例
        • 实例索引和实例计数
      • 分区
      • 测试
      • 健康指示器
      • 示例
    • 绑定器
      • Apache Kafka
        • Kafka 绑定器
          • 使用
          • 概述
          • 配置选项
          • 重置偏移量
          • 消费批次
          • 手动确认
          • 安全配置
          • 暂停和恢复消费者
          • 事务绑定器
          • 错误通道
          • Kafka 指标
          • 墓碑记录
          • KafkaBindingRebalanceListener
          • 重试和死信处理
          • Kafka Binder 监听容器定制器
          • 自定义消费者和生产者配置
          • 自定义 AdminClient 配置
          • 自定义 Kafka 绑定器健康指示器
          • 死信主题处理
          • 死信主题分区选择
          • 使用 Kafka 绑定器进行分区
        • Reactive Kafka 绑定器
          • 概述
          • Maven 坐标
          • 使用 Reactive Kafka 绑定器的基本示例
          • 消费记录
          • 并发
          • 多路复用
          • 目标是模式
          • 发送方结果通道
          • Reactor Kafka 绑定器健康指示器
          • Reactive Kafka Binder 中的可观测性
        • Kafka Stream 绑定器
          • 用法
          • 概述
          • 编程模型
          • 编程模型的辅助功能
          • 记录序列化和反序列化
          • 错误处理
          • 重试关键业务逻辑
          • 状态存储
          • 交互式查询
          • 健康指示器
          • 访问 Kafka Streams 指标
          • 混合高级 DSL 和低级 Processor API
          • 出站分区支持
          • StreamsBuilderFactoryBean 配置器
          • 时间戳提取器
          • 带有 Kafka Streams 绑定器和常规 Kafka 绑定器的多绑定器
          • 状态清理
          • Kafka Streams 拓扑可视化
          • Kafka Streams 应用程序中基于事件类型的路由
          • Kafka Streams 绑定器中的绑定可视化和控制
          • 手动启动 Kafka Streams 处理器
          • 手动选择性启动 Kafka Streams 处理器
          • 使用 Spring Cloud Sleuth 进行追踪
          • 配置选项
        • 技巧和秘诀
          • 提示、技巧和秘诀
      • RabbitMQ Binder 参考指南
        • 配置选项
          • RabbitMQ 绑定器属性
          • RabbitMQ 消费者属性
          • RabbitMQ 生产者属性
          • 高级监听器容器配置
          • 高级配置
          • 接收批量消息
          • 发布者确认
          • RabbitMQ Stream 插件的初步消费者支持
          • RabbitMQ Stream 插件的初步生产者支持
        • 使用现有队列/交换机
        • 使用 RabbitMQ 绑定器重试
          • 整合所有内容
        • 错误通道
        • 使用 RabbitMQ 绑定器进行分区
        • Rabbit 绑定器健康指示器
      • Apache Pulsar
        • Spring Cloud Stream Apache Pulsar 绑定器
      • Solace
      • Amazon Kinesis
    • Spring Cloud Stream Schema Registry
  • Spring Cloud Stream 中文文档
  • Spring Cloud Stream Kafka 绑定器参考指南

Spring Cloud Stream Kafka 绑定器参考指南

参考指南

粤ICP备2024239452号-1