Spring
Why Spring
Overview Microservices Reactive Event Driven Cloud Web Applications Serverless Batch
Learn
Overview Quickstart Guides Blog
Projects
Overview Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security View all projects
  • DEVELOPMENT TOOLS
    • Spring Tools 4 Spring Initializr
    Academy
    Courses Get Certified
    Solutions
    Overview Spring Runtime Spring Consulting Spring Academy For Teams Security Advisories
    Community
    Overview Events Team
    spring-cloud-stream 4.1.4
      • 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
            • Reactor Kafka Binder Health Indicator
          • 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
    Edit this Page GitHub Project Stack Overflow

    For the latest stable version, please use spring-cloud-stream 4.2.0!
    • spring-cloud-stream
    • Spring Cloud Stream Kafka Streams Binder Reference Guide

    Spring Cloud Stream Kafka Streams Binder Reference Guide

    Reference Guide

    • spring-cloud-stream
      • 4.2.1-SNAPSHOT
      • 4.2.0current
      • 4.1.5-SNAPSHOT
      • 4.1.4
    • Related Spring Documentation
      • Spring Boot
      • Spring Framework
      • Spring Cloud
        • Spring Cloud Build
        • Spring Cloud Bus
        • Spring Cloud Circuit Breaker
        • 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 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
      • All Docs...
    Spring

    Copyright © 2005 - Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
    Terms of Use • Privacy • Trademark Guidelines • Thank you • Your California Privacy Rights • Cookie Settings

    Apache®, Apache Tomcat®, Apache Kafka®, Apache Cassandra™, and Apache Geode™ are trademarks or registered trademarks of the Apache Software Foundation in the United States and/or other countries. Java™, Java™ SE, Java™ EE, and OpenJDK™ are trademarks of Oracle and/or its affiliates. Kubernetes® is a registered trademark of the Linux Foundation in the United States and other countries. Linux® is the registered trademark of Linus Torvalds in the United States and other countries. Windows® and Microsoft® Azure are registered trademarks of Microsoft Corporation. “AWS” and “Amazon Web Services” are trademarks or registered trademarks of Amazon.com Inc. or its affiliates. All other trademarks and copyrights are property of their respective owners and are only mentioned for informative purposes. Other names may be trademarks of their respective owners.

    Search in all Spring Docs