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 Runtime Spring Consulting Spring Academy For Teams 安全公告
    社区
    概述 活动 团队
    spring-cloud-stream 4.1.2
      • Spring 数据集成之旅的简史
      • 简介
      • Spring Cloud Stream 参考文档
        • 主要概念和抽象
          • Spring Cloud Stream 的应用程序模型
          • Binder 抽象
          • 持久发布-订阅支持
          • 消费者组支持
          • 分区支持
        • 编程模型
          • 目标 Binder
          • 绑定
          • 绑定和绑定名称
          • 函数绑定名称
          • 显式绑定创建
          • 绑定可视化和控制
          • 生成和消费消息
          • 事件路由
          • 后处理（发送消息后）
        • Binder 抽象
          • 可插拔 Binder SPI
          • Binder 检测
          • 类路径上的多个 Binder
          • 连接到多个系统
          • 在多 Binder 应用程序中自定义 Binder
        • 错误处理
        • 可观察性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机制
          • 提供的 MessageConverters
          • 用户定义的 Message Converters
        • 应用程序间通信
          • 连接多个应用程序实例
          • 实例索引和实例计数
        • 分区
        • 测试
        • 健康指示器
        • 示例
      • Binder
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 消费批处理
            • 手动确认
            • 安全配置
            • 暂停和恢复消费者
            • 事务性 Binder
            • 错误通道
            • Kafka 指标
            • 墓碑记录
            • KafkaBindingRebalanceListener
            • 重试和死信处理
            • 自定义消费者和生产者配置
            • 自定义 AdminClient 配置
            • 自定义 Kafka Binder 健康指示器
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka Binder 进行分区
          • 响应式 Kafka Binder
            • 概述
            • Maven 坐标
            • 使用响应式 Kafka Binder 的基本示例
            • 消费记录
            • 并发
            • 多路复用
            • 目的地是模式
            • 发送者结果通道
            • Reactor Kafka Binder 健康指示器
          • Kafka 流 Binder
            • 用法
            • 概述
            • 编程模型
            • 编程模型的辅助工具
            • 记录序列化和反序列化
            • 错误处理
            • 重试关键业务逻辑
            • 状态存储
            • 交互式查询
            • 健康指示器
            • 访问 Kafka 流指标
            • 混合高级 DSL 和低级处理器 API
            • 输出上的分区支持
            • StreamsBuilderFactoryBean 配置器
            • 时间戳提取器
            • 基于 Kafka 流的 Binder 和常规 Kafka Binder 的多 Binder
            • 状态清理
            • Kafka 流拓扑可视化
            • Kafka 流应用程序中的基于事件类型的路由
            • Kafka 流 Binder 中的绑定可视化和控制
            • 手动启动 Kafka 流处理器
            • 有选择地手动启动 Kafka 流处理器
            • 使用 Spring Cloud Sleuth 进行跟踪
            • 配置选项
          • 提示和秘籍
            • 提示、技巧和秘籍
        • RabbitMQ Binder 参考指南
          • 配置选项
            • RabbitMQ Binder 属性
            • RabbitMQ 消费者属性
            • RabbitMQ 生产者属性
            • 高级监听器容器配置
            • 高级配置
            • 接收批处理消息
            • 发布者确认
            • RabbitMQ 流插件的初始消费者支持
            • RabbitMQ 流插件的初始生产者支持
          • 使用现有队列/交换
          • 使用 RabbitMQ Binder 重试
            • 将所有内容放在一起
          • 错误通道
          • 使用 RabbitMQ Binder 进行分区
          • Rabbit Binder 健康指示器
        • Apache Pulsar
          • 适用于 Apache Pulsar 的 Spring Cloud 流 Binder
        • Solace
        • Amazon Kinesis
      • Spring Cloud 流模式注册表
    编辑此页 GitHub 项目 Stack Overflow
    • spring-cloud-stream
    • Spring Cloud Stream Kafka Streams Binder 参考指南

    Spring Cloud Stream Kafka Streams Binder 参考指南

    参考指南

    • spring-cloud-stream
      • 4.1.3-SNAPSHOT
      • 4.1.2当前
    • 相关的 Spring 文档
      • 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 集成
      • Spring 批处理
      • Spring Security
        • Spring 授权服务器
        • Spring LDAP
        • Spring Security Kerberos
        • Spring 会话
        • Spring Vault
      • Spring AI
      • Spring AMQP
      • Spring CLI
      • Spring GraphQL
      • Spring for Apache Kafka
      • Spring Modulith
      • Spring for Apache Pulsar
      • Spring Shell
      • 所有文档...
    Spring

    版权所有 © 2005 - 博通。保留所有权利。“博通”一词指博通公司和/或其子公司。
    使用条款 • 隐私 • 商标指南 • 感谢 • 您的加州隐私权 • Cookie 设置

    Apache®、Apache Tomcat®、Apache Kafka®、Apache Cassandra™ 和 Apache Geode™ 是 Apache 软件基金会在美国和/或其他国家/地区的商标或注册商标。Java™、Java™ SE、Java™ EE 和 OpenJDK™ 是 Oracle 和/或其关联公司的商标。Kubernetes® 是 Linux 基金会在美国和其他国家/地区的注册商标。Linux® 是 Linus Torvalds 在美国和其他国家/地区的注册商标。Windows® 和 Microsoft® Azure 是 Microsoft Corporation 的注册商标。“AWS”和“Amazon Web Services”是 Amazon.com Inc. 或其关联公司的商标或注册商标。所有其他商标和版权均为其各自所有者的财产，仅出于信息目的而提及。其他名称可能是其各自所有者的商标。

    在所有 Spring 文档中搜索