Spring
Ollama文档
Grok文档
OpenAI文档
Pytorch文档
Anaconda文档
Redis文档
CursorAI文档
markdown教程
LangChain开发文档
全部版本
切换语言
中文 English
所有文档
  • 最新文档
  • Spring AI Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security 全部项目
  • 开发工具(英文)
  • Spring.io Spring Tools 4 Spring Initializr
    spring-cloud-stream 5.0.0
      • 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
            • Kafka Binder Listener Container Customizers
            • 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
            • Reactor Kafka Binder Health Indicator
            • Observability in Reactive Kafka Binder
          • 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
    GitHub Project

    Maven Coordinates

    Following are the maven coordinates for the reactive Kafka binder.spring-doc.cn

    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-stream-binder-kafka-reactive</artifactId>
    </dependency>
    • spring-cloud-stream
    • Maven Coordinates

    Overview Basic Example using the Reactive Kafka Binder
    Spring

    本站点文档内容均由 Spring官网 翻译而来,翻译内容可能存在遗漏或偏差,仅供个人学习,准确内容请以 Spring官网英文文档 为准。
    Copyright © 2005 - 2025 南京筱麦软件有限公司 ( 苏ICP备2022047690号-3 | 苏公网安备32011402011833 )