Spring
分析&设计
设计模式 课程 设计思维 课程
AI 系列
ChatGPT 简明教程 Spring AI
机器学习
机器学习 基础 机器学习 With Python Pytorch 教程
Java教程
Java 基础 Java Concurrency java Nio
Python教程
Python 基础 Python Pandas
Spring Cloud Stream 中文文档
    • A Brief History of Spring’s Data Integration Journey
    • Introduction
    • Spring Cloud Stream Reference Documentation
      • Main Concepts and Abstractions
        • Spring Cloud Stream’s application model
        • The Binder Abstraction
        • Persistent publish-subscribe support
        • Consumer group support
        • Partitioning support
      • Programming Model
        • Destination Binders
        • Bindings
        • Binding and Binding names
        • Functional binding names
        • Explicit binding creation
        • Binding visualization and control
        • Producing and Consuming Messages
        • Event Routing
        • Post processing (after sending message)
      • Binder abstraction
        • A pluggable Binder SPI
        • Binder Detection
        • Multiple Binders on the Classpath
        • Connecting to Multiple Systems
        • Customizing binders in multi binder applications
      • Error Handling
      • Observability
      • Configuration Options
        • Binding Service Properties
        • Binding Properties
      • Content Type Negotiation
        • Mechanics
        • Provided MessageConverters
        • User-defined Message Converters
      • Inter-Application Communication
        • Connecting Multiple Application Instances
        • Instance Index and Instance Count
      • Partitioning
      • Testing
      • Health Indicator
      • Samples
    • Binders
      • Apache Kafka
        • Kafka Binder
          • Usage
          • Overview
          • Configuration Options
          • Resetting Offsets
          • Consuming Batches
          • Manual Acknowledgement
          • Security Configuration
          • Pausing and Resuming the Consumer
          • Transactional Binder
          • Error Channels
          • Kafka Metrics
          • Tombstone Records
          • KafkaBindingRebalanceListener
          • Retry and Dead Letter Processing
          • Customizing Consumer and Producer configuration
          • Customizing AdminClient Configuration
          • Custom Kafka Binder Health Indicator
          • Dead-Letter Topic Processing
          • Dead-Letter Topic Partition Selection
          • Partitioning with the Kafka Binder
        • Reactive Kafka Binder
          • Overview
          • Maven Coordinates
          • Basic Example using the Reactive Kafka Binder
          • Consuming Records
          • Concurrency
          • Multiplex
          • Destination is Pattern
          • Sender Result Channel
        • Kafka Stream Binder
          • Usage
          • Overview
          • Programming Model
          • Ancillaries to the programming model
          • Record serialization and deserialization
          • Error Handling
          • Retrying critical business logic
          • State Store
          • Interactive Queries
          • Health Indicator
          • Accessing Kafka Streams Metrics
          • Mixing high level DSL and low level Processor API
          • Partition support on the outbound
          • StreamsBuilderFactoryBean configurer
          • Timestamp extractor
          • Multi binders with Kafka Streams based binders and regular Kafka Binder
          • State Cleanup
          • Kafka Streams topology visualization
          • Event type based routing in Kafka Streams applications
          • Binding visualization and control in Kafka Streams binder
          • Manually starting Kafka Streams processors
          • Manually starting Kafka Streams processors selectively
          • Tracing using Spring Cloud Sleuth
          • Configuration Options
        • Tips and Recipes
          • Tips, Tricks and Recipes
      • RabbitMQ Binder Reference Guide
        • Configuration Options
          • RabbitMQ Binder Properties
          • RabbitMQ Consumer Properties
          • RabbitMQ Producer Properties
          • Advanced Listener Container Configuration
          • Advanced Configuration
          • Receiving Batched Messages
          • Publisher Confirms
          • Initial Consumer Support for the RabbitMQ Stream Plugin
          • Initial Producer Support for the RabbitMQ Stream Plugin
        • Using Existing Queues/Exchanges
        • Retry With the RabbitMQ Binder
          • Putting it All Together
        • Error Channels
        • Partitioning with the RabbitMQ Binder
        • Rabbit Binder Health Indicator
      • Apache Pulsar
        • Spring Cloud Stream Binder for Apache Pulsar
      • Solace
      • Amazon Kinesis
    • Spring Cloud Stream Schema Registry
  • Spring Cloud Stream 中文文档
  • Spring Cloud Stream Pulsar Binder Reference Guide

Spring Cloud Stream Pulsar Binder Reference Guide

Pulsar Binder 使开发人员能够将各种事件源和接收器连接在一起，从而为数据管道创建强大的端到端解决方案。它还支持状态管理和并行处理，从而提供了可扩展且高性能的实时数据处理。 Soby Chacko; Chris Bono; Alexander Preuß; Jay Bryant; Christophe Bornet

Reference Guide

  • Spring Ai 中文文档
    • defaultcurrent
  • Spring Amqp 中文文档
    • defaultcurrent
  • Spring Authorization-server 中文文档
    • defaultcurrent
  • Spring Batch 中文文档
    • defaultcurrent
  • Spring Boot 中文文档
    • defaultcurrent
  • Spring Cli 中文文档
    • defaultcurrent
  • Spring Cloud Build 中文文档
    • defaultcurrent
  • Spring Cloud Bus 中文文档
    • defaultcurrent
  • Spring Cloud Circuitbreaker 中文文档
    • defaultcurrent
  • Spring Cloud Commons 中文文档
    • defaultcurrent
  • Spring Cloud Config 中文文档
    • defaultcurrent
  • Spring Cloud Consul 中文文档
    • defaultcurrent
  • Spring Cloud Contract 中文文档
    • defaultcurrent
  • Spring Cloud Function 中文文档
    • defaultcurrent
  • Spring Cloud Gateway 中文文档
    • defaultcurrent
  • Spring Cloud Kubernetes 中文文档
    • defaultcurrent
  • Spring Cloud Netflix 中文文档
    • defaultcurrent
  • Spring Cloud Openfeign 中文文档
    • defaultcurrent
  • Spring Cloud Stream 中文文档
    • defaultcurrent
  • Spring Cloud Task 中文文档
    • defaultcurrent
  • Spring Cloud Vault 中文文档
    • defaultcurrent
  • Spring Cloud Zookeeper 中文文档
    • defaultcurrent
  • Spring Data Cassandra 中文文档
    • defaultcurrent
  • Spring Data Commons 中文文档
    • defaultcurrent
  • Spring Data Couchbase 中文文档
    • defaultcurrent
  • Spring Data Elasticsearch 中文文档
    • defaultcurrent
  • Spring Data Jpa 中文文档
    • defaultcurrent
  • Spring Data Keyvalue 中文文档
    • defaultcurrent
  • Spring Data Ldap 中文文档
    • defaultcurrent
  • Spring Data Mongodb 中文文档
    • defaultcurrent
  • Spring Data Neo4j 中文文档
    • defaultcurrent
  • Spring Data Redis 中文文档
    • defaultcurrent
  • Spring Data Relational 中文文档
    • defaultcurrent
  • Spring data Rest 中文文档
    • defaultcurrent
  • Spring Framework 中文文档
    • defaultcurrent
  • Spring Graphql 中文文档
    • defaultcurrent
  • Spring Integration 中文文档
    • defaultcurrent
  • Spring Kafka 中文文档
    • defaultcurrent
  • Spring Ldap 中文文档
    • defaultcurrent
  • Spring Modulith 中文文档
    • defaultcurrent
  • Spring Pulsar 中文文档
    • defaultcurrent
  • Spring Security 中文文档
    • defaultcurrent
  • Spring Session 中文文档
    • defaultcurrent
  • Spring Shell 中文文档
    • defaultcurrent
  • Spring Vault 中文文档
    • defaultcurrent

粤ICP备2024239452号-1