Spring
Ollama文档
Grok文档
OpenAI文档
Pytorch文档
Copilot文档
OpenClaw文档
GeminiAI文档
markdown教程
LangChain开发文档
全部版本
切换语言
中文 English
所有文档
  • 最新文档
  • Spring AI Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security 全部项目
  • 开发工具(英文)
  • Spring.io Spring Tools 4 Spring Initializr
    spring-cloud-stream (spring-cloud-stream) 5.0.1
      • 一个关于Spring数据集成之旅的简短历史记录
      • 介绍
      • Spring Cloud Stream参考文档
        • Main Concepts and Abstractions
          • Spring Cloud Stream 的应用模型
          • Spring 框架的绑定器抽象
          • 可持久化发布-订阅支持
          • Consumer group support
          • Partitioning support
        • 编程模型
          • 目标绑定器
          • Bindings
          • 绑定和绑定名
          • 功能绑定名称
          • 显式绑定创建
          • Spring框架的绑定可视化和控制(官方教程)
          • 消息的生产和消费
          • 事件路由
          • 处理(在发送消息之后)
        • 绑定抽象<br/>
          • A pluggable Binder SPI
          • Binder Detection
          • <h2>类路径上的多个绑定器</h2>
          • 连接多个系统
          • 定制多绑定器应用程序中的绑定器
        • 错误处理
        • 可观测性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机械学
          • 提供的 MessageConverters
          • 用户自定义消息转换器
        • 跨应用程序通信
          • 连接多个应用程序实例
          • 实例索引和实例计数
        • 分区
        • 测试
        • 健康指标
        • 示例
      • Binders
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 消费批次
            • 手动确认
            • 安全配置
            • 暂停并恢复消费者
            • 事务性绑定器
            • Error Channels
            • Kafka 指标
            • Tombstone Records
            • KafkaBindingRebalanceListener
            • <h2>重试和死信处理</h2>
            • Kafka 绑定侦听器容器自定义程序
            • 自定义消费者和生产者配置
            • 自定义AdminClient配置项
            • 自定义 Kafka Binder 健康指标
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka 绑定进行分区
          • Reactive Kafka Binder
            • 概述
            • Maven 坐标
            • 使用响应式Kafka绑定器的基本示例
            • 消费记录
            • 并发
            • 多路复用
            • 目的地是模式
            • 渠道结果发送程序
            • Reactor Kafka绑定程序健康指示器
            • 可观测性在Reactive Kafka Binder中
          • Kafka Stream Binder
            • 用法
            • 概述
            • 编程模型
            • Ancillaries to the programming model
            • 记录序列化和反序列化
            • 错误处理
            • 重试关键业务逻辑
            • 状态存储
            • 互动查询
            • 健康指标
            • 访问Kafka流度量
            • Mixing high level DSL and low level Processor API
            • 出站的分区支持
            • StreamsBuilderFactoryBean 配置器
            • 时间戳提取器
            • 带有Kafka Streams绑定器和常规Kafka绑定器的多个绑定程序
            • 状态清理
            • Kafka 流处理拓扑可视化
            • 根据事件类型在 Kafka 流应用程序中进行路由
            • 在 Kafka Streams 绑定中进行绑定可视化和控制
            • 手动启动Kafka Streams处理器
            • 按需手动启动Kafka Streams处理器
            • 使用Spring CloudSleuth跟踪
            • 配置选项
          • Tips and Recipes
            • 提示、技巧和配方
        • RabbitMQ绑定程序参考指南
          • Configuration Options
            • 消息队列绑定器属性
            • 使用 RabbitMQ 的消费者属性
            • RabbitMQ 生产者属性
            • 高级侦听程序容器配置
            • 高级配置
            • 接收批量消息
            • 发行商确认
            • RabbitMQ 流插件的初始消费者支持
            • 初始对 RabbitMQ 流插件的生产者支持
          • 使用现有的队列/交换器
          • <span>重试与RabbitMQ绑定器</span>
            • 整合在一起
          • Error Channels
          • 使用 RabbitMQ 绑定程序进行分区
          • Rabbit 绑定状况指标
        • Apache Pulsar
          • Apache Pulsar 的 Spring Cloud Stream 绑定器
        • Solace
        • Amazon Kinesis
      • <span>模式注册表</span>
    GitHub Project

    Maven 坐标

    以下是响应式 Kafka 绑定的 Maven 坐标。spring-doc.cadn.net.cn

    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-stream-binder-kafka-reactive</artifactId>
    </dependency>
    • spring-cloud-stream
    • Maven 坐标

    概述 使用响应式Kafka绑定器的基本示例
    Spring

    本站点文档内容均由 Spring官网 翻译而来,翻译内容可能存在遗漏或偏差,仅供个人学习,准确内容请以 Spring官网英文文档 为准。
    Copyright © 2005 - 2026 南京筱麦软件有限公司 ( 苏ICP备2022047690号-3 | 苏公网安备32011402011833 )