Spring
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