Spring
Ollama文档
Grok文档
OpenAI文档
Pytorch文档
Anaconda文档
Redis文档
CursorAI文档
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) 4.2.3-SNAPSHOT
      • 春季数据集成历程简史
      • 介绍
      • 春云溪流参考文档
        • 主要概念和抽象
          • Spring Cloud Stream 的应用模型
          • 活页夹抽象
          • 持续的发布-订阅支持
          • Consumer group support
          • Partitioning support
        • 编程模型
          • 目的地活页夹
          • 绑定
          • 装订与配对名称
          • 功能性结合名称
          • 显式绑定创建
          • 绑定可视化与控制
          • 生成与消费信息
          • 事件路由
          • 后处理(发送消息后)
        • 结合剂抽象
          • A pluggable Binder SPI
          • 束缚剂检测
          • 类路径上的多个活页夹
          • 连接多系统
          • 在多活页夹应用中定制活页夹
        • 错误处理
        • 可观察性
        • 配置选项
          • 绑定服务属性
          • 结合性质
        • 内容类型协商
          • Mechanics
          • 提供的消息转换器
          • 用户自定义消息转换器
        • 应用间通信
          • 连接多个应用实例
          • 实例索引与实例计数
        • 分区
        • 测试
        • 健康指标
        • Samples
      • Binders
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 消耗批次
            • 手动确认
            • 安全配置
            • 暂停与恢复消费者
            • 交易活页夹
            • 错误信道
            • 卡夫卡度量
            • 墓碑唱片
            • KafkaBindingRebalanceListener
            • 重试与死信处理
            • Kafka Binder Listener Container Customizers
            • 定制消费者和生产者配置
            • 定制AdminClient配置
            • 自定义Kafka活页夹健康指示器
            • 死字母主题处理
            • 死字主题划分选择
            • 卡夫卡装订器划分
          • Reactive Kafka Binder
            • 概述
            • Maven坐标
            • 使用响应式卡夫卡活页夹的基本示例
            • 消费唱片
            • 并发
            • 多重
            • 目的地是模式
            • 发送者结果通道
            • 反应堆卡夫卡束剂健康指示器
            • 响应式卡夫卡活字器中的可观测性
          • Kafka Stream Binder
            • 用法
            • 概述
            • 编程模型
            • 编程模型的辅助
            • 记录序列化与反串列化
            • 错误处理
            • 重试关键业务逻辑
            • 州商店
            • 交互式查询
            • 健康指标
            • 访问Kafka Streams Metrics
            • 混合高级DSL和低级处理器API
            • 出站分区支持
            • StreamsBuilderFactoryBean 配置器
            • 时间戳提取器
            • 多重活页夹,结合基于Kafka Streams的活页夹和普通Kafka活页夹
            • 州级清理
            • Kafka Streams 拓扑可视化
            • Kafka Streams 应用中的基于事件类型的路由
            • Kafka Streams 绑定器中的绑定可视化与控制
            • 手动启动Kafka Streams处理器
            • 手动选择性启动Kafka Streams处理器
            • 使用春云侦探进行追踪
            • 配置选项
          • Tips and Recipes
            • 技巧、窍门和Recipes
        • RabbitMQ Binder 参考指南
          • 配置选项
            • RabbitMQ Binder 属性
            • RabbitMQ 消费者属性
            • RabbitMQ 生产者属性
            • Advanced Listener Container Configuration
            • 高级配置
            • 接收批量消息
            • 出版商确认
            • RabbitMQ Stream插件的初始消费者支持
            • RabbitMQ Stream插件的初始生产者支持
          • 使用现有队列/交换
          • 用RabbitMQ文件夹重试
            • 把一切整合起来
          • 错误信道
          • RabbitMQ 绑定器的分区
          • 兔子绑定器健康指标
        • Apache Pulsar
          • Spring Cloud Stream Binder for Apache Pulsar
        • Solace
        • Amazon Kinesis
      • Spring Cloud Stream Schema Registry
    GitHub Project

    该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 spring-cloud-stream 5.0.0!spring-doc.cadn.net.cn

    Maven坐标

    以下是响应式卡夫卡结合器的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坐标

    概述 使用响应式卡夫卡活页夹的基本示例
    Spring

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