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 运行时 Spring 咨询 Spring 学院团队 安全公告
    社区
    概述 活动 团队
    spring-cloud-stream 4.1.3
      • Spring 数据集成历程简史
      • 简介
      • Spring Cloud Stream 参考文档
        • 主要概念和抽象
          • Spring Cloud Stream 的应用程序模型
          • 绑定器抽象
          • 持久发布-订阅支持
          • 消费者组支持
          • 分区支持
        • 编程模型
          • 目标绑定器
          • 绑定
          • 绑定和绑定名称
          • 功能绑定名称
          • 显式绑定创建
          • 绑定可视化和控制
          • 生产和消费消息
          • 事件路由
          • 后处理（发送消息后）
        • 绑定器抽象
          • 可插拔绑定器 SPI
          • 绑定器检测
          • 类路径上的多个绑定器
          • 连接到多个系统
          • 在多绑定器应用程序中自定义绑定器
        • 错误处理
        • 可观察性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机制
          • 提供的 MessageConverters
          • 用户定义的 Message Converters
        • 应用程序间通信
          • 连接多个应用程序实例
          • 实例索引和实例计数
        • 分区
        • 测试
        • 健康指示器
        • 示例
      • 绑定器
        • Apache Kafka
          • Kafka 绑定器
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 消费批次
            • 手动确认
            • 安全配置
            • 暂停和恢复消费者
            • 事务性绑定器
            • 错误通道
            • Kafka 指标
            • 墓碑记录
            • KafkaBindingRebalanceListener
            • 重试和死信处理
            • 自定义消费者和生产者配置
            • 自定义 AdminClient 配置
            • 自定义 Kafka 绑定器健康指示器
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka 绑定器进行分区
          • Reactive Kafka 绑定器
            • 概述
            • Maven 坐标
            • 使用 Reactive Kafka 绑定器的基本示例
            • 消费记录
            • 并发
            • 多路复用
            • 目标是模式
            • 发送者结果通道
            • Reactor Kafka 绑定器健康指示器
          • 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 绑定器参考指南
          • 配置选项
            • RabbitMQ 绑定器属性
            • RabbitMQ 消费者属性
            • RabbitMQ 生产者属性
            • 高级监听器容器配置
            • 高级配置
            • 接收批量消息
            • 发布者确认
            • RabbitMQ Stream 插件的初始消费者支持
            • RabbitMQ Stream 插件的初始生产者支持
          • 使用现有的队列/交换机
          • 使用 RabbitMQ 绑定器重试
            • 整合所有内容
          • 错误通道
          • 使用 RabbitMQ 绑定器进行分区
          • Rabbit 绑定器健康指示器
        • Apache Pulsar
          • Apache Pulsar 的 Spring Cloud Stream 绑定器
        • Solace
        • Amazon Kinesis
      • Spring Cloud Stream Schema 注册中心
    编辑此页面 GitHub 项目 Stack Overflow
    • spring-cloud-stream
    • Spring Cloud Stream Kafka Streams 绑定器参考指南

    Spring Cloud Stream Kafka Streams 绑定器参考指南

    参考指南

    • spring-cloud-stream
      • 4.2.0-SNAPSHOT
      • 4.2.0-RC1
      • 4.1.4-SNAPSHOT
      • 4.1.3当前
    • 相关 Spring 文档
      • Spring Boot
      • Spring Framework
      • Spring Cloud
        • Spring Cloud Build
        • Spring Cloud Bus
        • Spring Cloud 断路器
        • 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 Integration
      • Spring Batch
      • Spring Security
        • Spring 授权服务器
        • Spring LDAP
        • Spring Security Kerberos
        • Spring Session
        • Spring Vault
      • Spring AI
      • Spring AMQP
      • Spring CLI
      • Spring GraphQL
      • Spring for Apache Kafka
      • Spring 模块化
      • Apache Pulsar 的 Spring
      • 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 文档