Spring
为何选择 Spring
概述 微服务 响应式 事件驱动 云 Web 应用 Serverless 批处理
学习
概述 快速入门 指南 博客
项目
概述 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 安全公告
    社区
    概述 活动 团队
    spring-cloud-stream 4.2.1
      • Spring 数据集成之旅的简要历史
      • 引言
      • Spring Cloud Stream 参考文档
        • 主要概念和抽象
          • Spring Cloud Stream 的应用模型
          • Binder 抽象
          • 持久化发布-订阅支持
          • 消费者组支持
          • 分区支持
        • 编程模型
          • 目标 Binder
          • 绑定
          • 绑定和绑定名称
          • 函数式绑定名称
          • 显式绑定创建
          • 绑定可视化和控制
          • 生产和消费消息
          • 事件路由
          • 后处理（发送消息后）
        • Binder 抽象
          • 可插拔的 Binder SPI
          • Binder 检测
          • Classpath 中的多个 Binder
          • 连接到多个系统
          • 在多 Binder 应用中定制 Binder
        • 错误处理
        • 可观测性
        • 配置选项
          • 绑定服务属性
          • 绑定属性
        • 内容类型协商
          • 机制
          • 提供的 MessageConverter
          • 用户自定义 Message Converter
        • 应用间通信
          • 连接多个应用实例
          • 实例索引和实例数量
        • 分区
        • 测试
        • 健康指示器
        • 示例
      • Binder
        • Apache Kafka
          • Kafka Binder
            • 用法
            • 概述
            • 配置选项
            • 重置偏移量
            • 消费批次
            • 手动确认
            • 安全配置
            • 暂停和恢复消费者
            • 事务性 Binder
            • 错误通道
            • Kafka 指标
            • 墓碑记录
            • KafkaBindingRebalanceListener
            • 重试和死信处理
            • Kafka Binder 监听器容器定制器
            • 定制消费者和生产者配置
            • 定制 AdminClient 配置
            • 定制 Kafka Binder 健康指示器
            • 死信主题处理
            • 死信主题分区选择
            • 使用 Kafka Binder 进行分区
          • 响应式 Kafka Binder
            • 概述
            • Maven 坐标
            • 使用 Reactive Kafka Binder 的基本示例
            • 消费记录
            • 并发
            • 多路复用
            • 目标是模式
            • 发送者结果通道
            • Reactor Kafka Binder 健康指示器
            • Reactive Kafka Binder 中的可观测性
          • Kafka Stream Binder
            • 用法
            • 概述
            • 编程模型
            • 编程模型的辅助功能
            • 记录序列化和反序列化
            • 错误处理
            • 重试关键业务逻辑
            • 状态存储
            • 交互式查询
            • 健康指示器
            • 访问 Kafka Streams 指标
            • 混合使用高级 DSL 和低级 Processor API
            • 出站分区支持
            • StreamsBuilderFactoryBean 配置器
            • 时间戳提取器
            • 基于 Kafka Streams 的 Binder 与常规 Kafka Binder 的多 Binder 配置
            • 状态清理
            • Kafka Streams 拓扑可视化
            • Kafka Streams 应用中基于事件类型的路由
            • Kafka Streams binder 中的绑定可视化和控制
            • 手动启动 Kafka Streams 处理器
            • 选择性地手动启动 Kafka Streams 处理器
            • 使用 Spring Cloud Sleuth 进行追踪
            • 配置选项
          • 技巧和秘诀
            • 技巧、诀窍和秘诀
        • RabbitMQ Binder 参考指南
          • 配置选项
            • RabbitMQ Binder 属性
            • RabbitMQ 消费者属性
            • RabbitMQ 生产者属性
            • 高级监听器容器配置
            • 高级配置
            • 接收批处理消息
            • 发布者确认
            • 对 RabbitMQ Stream 插件的初始消费者支持
            • 对 RabbitMQ Stream 插件的初始生产者支持
          • 使用现有队列/交换机
          • 使用 RabbitMQ Binder 进行重试
            • 整合所有功能
          • 错误通道
          • 使用 RabbitMQ Binder 进行分区
          • Rabbit Binder 健康指示器
        • Apache Pulsar
          • Spring Cloud Stream 的 Apache Pulsar Binder
        • Solace
        • Amazon Kinesis
      • Spring Cloud Stream Schema Registry
    编辑此页 GitHub 项目 Stack Overflow
    • spring-cloud-stream
    • Spring Cloud Stream Pulsar Binder 参考指南

    Spring Cloud Stream Pulsar Binder 参考指南

    参考指南

    • spring-cloud-stream
      • 4.3.0-SNAPSHOT
      • 4.3.0-RC1
      • 4.2.1当前
      • 4.1.6-SNAPSHOT
      • 4.1.5
    • 相关 Spring 文档
      • Spring Boot
      • Spring Framework
      • Spring Cloud
        • Spring Cloud 构建
        • Spring Cloud 总线
        • Spring Cloud 断路器
        • Spring Cloud 通用
        • Spring Cloud 配置
        • Spring Cloud Consul
        • Spring Cloud 合约
        • Spring Cloud 函数
        • Spring Cloud 网关
        • Spring Cloud Kubernetes
        • Spring Cloud Netflix
        • Spring Cloud OpenFeign
        • Spring Cloud Stream
        • Spring Cloud 任务
        • Spring Cloud Vault
        • Spring Cloud Zookeeper
      • Spring Data
        • Spring Data Cassandra
        • Spring Data 通用
        • Spring Data Couchbase
        • Spring Data Elasticsearch
        • Spring Data JPA
        • Spring Data 键值对
        • 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 Authorization Server
        • Spring LDAP
        • Spring Security Kerberos
        • Spring Session
        • Spring Vault
      • Spring AI
      • Spring AMQP
      • Spring CLI
      • Spring GraphQL
      • Spring for Apache Kafka
      • Spring Modulith
      • Spring for Apache Pulsar
      • Spring Shell
      • 所有文档...
    Spring

    版权所有 © 2005 -Broadcom。保留所有权利。“Broadcom”一词指 Broadcom Inc. 和/或其子公司。
    使用条款 • 隐私 • 商标指南 • 感谢 • 您的加州隐私权 • 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 是微软公司的注册商标。“AWS”和“Amazon Web Services”是 Amazon.com Inc. 或其附属公司的商标或注册商标。所有其他商标和版权均为其各自所有者的财产，仅用于提供信息目的。其他名称可能是其各自所有者的商标。

    在所有 Spring 文档中搜索