3 lines
19 KiB
HTML
3 lines
19 KiB
HTML
<html><head>
|
|
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
|
|
<title>Spring Cloud Stream Reference Guide</title><link rel="stylesheet" type="text/css" href="css/manual-multipage.css"><meta name="generator" content="DocBook XSL Stylesheets V1.79.1"><link rel="home" href="multi_spring-cloud-stream.html" title="Spring Cloud Stream Reference Guide"><link rel="next" href="multi__preface.html" title="Part I. Preface"></head><body class="firstpage" bgcolor="white" text="black" link="#0000FF" vlink="#840084" alink="#0000FF"><div class="navheader"><table width="100%" summary="Navigation header"><tr><th colspan="3" align="center">Spring Cloud Stream Reference Guide</th></tr><tr><td width="20%" align="left"> </td><th width="60%" align="center"> </th><td width="20%" align="right"> <a accesskey="n" href="multi__preface.html">Next</a></td></tr></table><hr></div><div lang="en" class="book"><div class="titlepage"><div><div><h1 class="title"><a name="d0e3"></a>Spring Cloud Stream Reference Guide</h1></div><div><div xmlns:d="http://docbook.org/ns/docbook" class="authorgroup"><h2>Authors</h2><span class="author"><span class="firstname">Sabby</span> <span class="surname">Anandan</span></span>, <span class="author"><span class="firstname">Marius</span> <span class="surname">Bogoevici</span></span>, <span class="author"><span class="firstname">Eric</span> <span class="surname">Bottard</span></span>, <span class="author"><span class="firstname">Mark</span> <span class="surname">Fisher</span></span>, <span class="author"><span class="firstname">Ilayaperumal</span> <span class="surname">Gopinathan</span></span>, <span class="author"><span class="firstname">Gunnar</span> <span class="surname">Hillert</span></span>, <span class="author"><span class="firstname">Mark</span> <span class="surname">Pollack</span></span>, <span class="author"><span class="firstname">Patrick</span> <span class="surname">Peralta</span></span>, <span class="author"><span class="firstname">Glenn</span> <span class="surname">Renfro</span></span>, <span class="author"><span class="firstname">Thomas</span> <span class="surname">Risberg</span></span>, <span class="author"><span class="firstname">Dave</span> <span class="surname">Syer</span></span>, <span class="author"><span class="firstname">David</span> <span class="surname">Turanski</span></span>, <span class="author"><span class="firstname">Janne</span> <span class="surname">Valkealahti</span></span>, <span class="author"><span class="firstname">Benjamin</span> <span class="surname">Klein</span></span>, <span class="author"><span class="firstname">Vinicius</span> <span class="surname">Carvalho</span></span>, <span class="author"><span class="firstname">Gary</span> <span class="surname">Russell</span></span>, <span class="author"><span class="firstname">Oleg</span> <span class="surname">Zhurakousky</span></span>, <span class="author"><span class="firstname">Jay</span> <span class="surname">Bryant</span></span></div></div></div><hr></div><div class="toc"><p><b>Table of Contents</b></p><dl class="toc"><dt><span class="part"><a href="multi__preface.html">I. Preface</a></span></dt><dd><dl><dt><span class="chapter"><a href="multi__a_brief_history_of_springs_data_integration_journey.html">1. A Brief History of Spring’s Data Integration Journey</a></span></dt><dt><span class="chapter"><a href="multi__quick_start.html">2. Quick Start</a></span></dt><dd><dl><dt><span class="section"><a href="multi__quick_start.html#spring-cloud-stream-preface-creating-sample-application">2.1. Creating a Sample Application by Using Spring Initializr</a></span></dt><dt><span class="section"><a href="multi__quick_start.html#spring-cloud-stream-preface-importing-project">2.2. Importing the Project into Your IDE</a></span></dt><dt><span class="section"><a href="multi__quick_start.html#spring-cloud-stream-preface-adding-message-handler">2.3. Adding a Message Handler, Building, and Running</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi__whats_new_in_2_0.html">3. What’s New in 2.0?</a></span></dt><dd><dl><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-new-features">3.1. New Features and Components</a></span></dt><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-notable-enhancements">3.2. Notable Enhancements</a></span></dt><dd><dl><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-actuator-web-dependencies">3.2.1. Both Actuator and Web Dependencies Are Now Optional</a></span></dt><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-content-type-negotiation-improvements">3.2.2. Content-type Negotiation Improvements</a></span></dt></dl></dd><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-notable-deprecations">3.3. Notable Deprecations</a></span></dt><dd><dl><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-deprecation-java-serialization">3.3.1. Java Serialization (Java Native and Kryo)</a></span></dt><dt><span class="section"><a href="multi__whats_new_in_2_0.html#spring-cloud-stream-preface-deprecation-classes-methods">3.3.2. Deprecated Classes and Methods</a></span></dt></dl></dd></dl></dd><dt><span class="chapter"><a href="multi_spring-cloud-stream-overview-introducing.html">4. Introducing Spring Cloud Stream</a></span></dt><dt><span class="chapter"><a href="multi__main_concepts.html">5. Main Concepts</a></span></dt><dd><dl><dt><span class="section"><a href="multi__main_concepts.html#spring-cloud-stream-overview-application-model">5.1. Application Model</a></span></dt><dd><dl><dt><span class="section"><a href="multi__main_concepts.html#_fat_jar">5.1.1. Fat JAR</a></span></dt></dl></dd><dt><span class="section"><a href="multi__main_concepts.html#spring-cloud-stream-overview-binder-abstraction">5.2. The Binder Abstraction</a></span></dt><dt><span class="section"><a href="multi__main_concepts.html#spring-cloud-stream-overview-persistent-publish-subscribe-support">5.3. Persistent Publish-Subscribe Support</a></span></dt><dt><span class="section"><a href="multi__main_concepts.html#consumer-groups">5.4. Consumer Groups</a></span></dt><dt><span class="section"><a href="multi__main_concepts.html#consumer-types">5.5. Consumer Types</a></span></dt><dd><dl><dt><span class="section"><a href="multi__main_concepts.html#durability">5.5.1. Durability</a></span></dt></dl></dd><dt><span class="section"><a href="multi__main_concepts.html#partitioning">5.6. Partitioning Support</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi__programming_model.html">6. Programming Model</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_destination_binders">6.1. Destination Binders</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_destination_bindings">6.2. Destination Bindings</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#spring-cloud-stream-overview-producing-consuming-messages">6.3. Producing and Consuming Messages</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_spring_integration_support">6.3.1. Spring Integration Support</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_using_streamlistener_annotation">6.3.2. Using @StreamListener Annotation</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_using_streamlistener_for_content_based_routing">6.3.3. Using @StreamListener for Content-based routing</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_spring_cloud_function">6.3.4. Spring Cloud Function support</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_functional_composition">Functional Composition</a></span></dt></dl></dd><dt><span class="section"><a href="multi__programming_model.html#spring-cloud-streams-overview-using-polled-consumers">6.3.5. Using Polled Consumers</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_overview">Overview</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#polled-errors">Handling Errors</a></span></dt></dl></dd></dl></dd><dt><span class="section"><a href="multi__programming_model.html#spring-cloud-stream-overview-error-handling">6.4. Error Handling</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_application_error_handling">6.4.1. Application Error Handling</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_system_error_handling">6.4.2. System Error Handling</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_drop_failed_messages">Drop Failed Messages</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_dlq_dead_letter_queue">DLQ - Dead Letter Queue</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_re_queue_failed_messages">Re-queue Failed Messages</a></span></dt></dl></dd><dt><span class="section"><a href="multi__programming_model.html#_retry_template">6.4.3. Retry Template</a></span></dt></dl></dd><dt><span class="section"><a href="multi__programming_model.html#spring-cloud-stream-overview-reactive-programming-support">6.5. Reactive Programming Support</a></span></dt><dd><dl><dt><span class="section"><a href="multi__programming_model.html#_reactor_based_handlers">6.5.1. Reactor-based Handlers</a></span></dt><dt><span class="section"><a href="multi__programming_model.html#_reactive_sources">6.5.2. Reactive Sources</a></span></dt></dl></dd></dl></dd><dt><span class="chapter"><a href="multi_spring-cloud-stream-overview-binders.html">7. Binders</a></span></dt><dd><dl><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#_producers_and_consumers">7.1. Producers and Consumers</a></span></dt><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#spring-cloud-stream-overview-binder-api">7.2. Binder SPI</a></span></dt><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#_binder_detection">7.3. Binder Detection</a></span></dt><dd><dl><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#_classpath_detection">7.3.1. Classpath Detection</a></span></dt></dl></dd><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#multiple-binders">7.4. Multiple Binders on the Classpath</a></span></dt><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#multiple-systems">7.5. Connecting to Multiple Systems</a></span></dt><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#_binding_visualization_and_control">7.6. Binding visualization and control</a></span></dt><dt><span class="section"><a href="multi_spring-cloud-stream-overview-binders.html#_binder_configuration_properties">7.7. Binder Configuration Properties</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi__configuration_options.html">8. Configuration Options</a></span></dt><dd><dl><dt><span class="section"><a href="multi__configuration_options.html#_binding_service_properties">8.1. Binding Service Properties</a></span></dt><dt><span class="section"><a href="multi__configuration_options.html#binding-properties">8.2. Binding Properties</a></span></dt><dd><dl><dt><span class="section"><a href="multi__configuration_options.html#_common_binding_properties">8.2.1. Common Binding Properties</a></span></dt><dt><span class="section"><a href="multi__configuration_options.html#_consumer_properties">8.2.2. Consumer Properties</a></span></dt><dt><span class="section"><a href="multi__configuration_options.html#_producer_properties">8.2.3. Producer Properties</a></span></dt></dl></dd><dt><span class="section"><a href="multi__configuration_options.html#dynamicdestination">8.3. Using Dynamically Bound Destinations</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi_content-type-management.html">9. Content Type Negotiation</a></span></dt><dd><dl><dt><span class="section"><a href="multi_content-type-management.html#_mechanics">9.1. Mechanics</a></span></dt><dd><dl><dt><span class="section"><a href="multi_content-type-management.html#_content_type_versus_argument_type">9.1.1. Content Type versus Argument Type</a></span></dt><dt><span class="section"><a href="multi_content-type-management.html#_message_converters">9.1.2. Message Converters</a></span></dt></dl></dd><dt><span class="section"><a href="multi_content-type-management.html#_provided_messageconverters">9.2. Provided MessageConverters</a></span></dt><dt><span class="section"><a href="multi_content-type-management.html#spring-cloud-stream-overview-user-defined-message-converters">9.3. User-defined Message Converters</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi_schema-evolution.html">10. Schema Evolution Support</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#_schema_registry_client">10.1. Schema Registry Client</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#_schema_registry_client_properties">10.1.1. Schema Registry Client Properties</a></span></dt></dl></dd><dt><span class="section"><a href="multi_schema-evolution.html#_avro_schema_registry_client_message_converters">10.2. Avro Schema Registry Client Message Converters</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#_avro_schema_registry_message_converter_properties">10.2.1. Avro Schema Registry Message Converter Properties</a></span></dt></dl></dd><dt><span class="section"><a href="multi_schema-evolution.html#_apache_avro_message_converters">10.3. Apache Avro Message Converters</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#_converters_with_schema_support">10.4. Converters with Schema Support</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#_schema_registry_server">10.5. Schema Registry Server</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#_schema_registry_server_api">10.5.1. Schema Registry Server API</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-registering-new-schema">Registering a New Schema</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-retrieve-schema-subject-format-version">Retrieving an Existing Schema by Subject, Format, and Version</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-retrieve-schema-subject-format">Retrieving an Existing Schema by Subject and Format</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-retrieve-schema-id">Retrieving an Existing Schema by ID</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-deleting-schema-subject-format-version">Deleting a Schema by Subject, Format, and Version</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-deleting-schema-id">Deleting a Schema by ID</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-deleting-schema-subject">Deleting a Schema by Subject</a></span></dt></dl></dd><dt><span class="section"><a href="multi_schema-evolution.html#_using_confluents_schema_registry">10.5.2. Using Confluent’s Schema Registry</a></span></dt></dl></dd><dt><span class="section"><a href="multi_schema-evolution.html#_schema_registration_and_resolution">10.6. Schema Registration and Resolution</a></span></dt><dd><dl><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-schema-registration-process">10.6.1. Schema Registration Process (Serialization)</a></span></dt><dt><span class="section"><a href="multi_schema-evolution.html#spring-cloud-stream-overview-schema-resolution-process">10.6.2. Schema Resolution Process (Deserialization)</a></span></dt></dl></dd></dl></dd><dt><span class="chapter"><a href="multi__inter_application_communication.html">11. Inter-Application Communication</a></span></dt><dd><dl><dt><span class="section"><a href="multi__inter_application_communication.html#spring-cloud-stream-overview-connecting-multiple-application-instances">11.1. Connecting Multiple Application Instances</a></span></dt><dt><span class="section"><a href="multi__inter_application_communication.html#spring-cloud-stream-overview-instance-index-instance-count">11.2. Instance Index and Instance Count</a></span></dt><dt><span class="section"><a href="multi__inter_application_communication.html#spring-cloud-stream-overview-partitioning">11.3. Partitioning</a></span></dt><dd><dl><dt><span class="section"><a href="multi__inter_application_communication.html#spring-cloud-stream-overview-configuring-output-bindings-partitioning">11.3.1. Configuring Output Bindings for Partitioning</a></span></dt><dt><span class="section"><a href="multi__inter_application_communication.html#spring-cloud-stream-overview-configuring-input-bindings-partitioning">11.3.2. Configuring Input Bindings for Partitioning</a></span></dt></dl></dd></dl></dd><dt><span class="chapter"><a href="multi__testing.html">12. Testing</a></span></dt><dd><dl><dt><span class="section"><a href="multi__testing.html#_disabling_the_test_binder_autoconfiguration">12.1. Disabling the Test Binder Autoconfiguration</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi__health_indicator.html">13. Health Indicator</a></span></dt><dt><span class="chapter"><a href="multi_spring-cloud-stream-overview-metrics-emitter.html">14. Metrics Emitter</a></span></dt><dt><span class="chapter"><a href="multi__samples.html">15. Samples</a></span></dt><dd><dl><dt><span class="section"><a href="multi__samples.html#_deploying_stream_applications_on_cloudfoundry">15.1. Deploying Stream Applications on CloudFoundry</a></span></dt></dl></dd><dt><span class="chapter"><a href="multi__binder_implementations.html">16. Binder Implementations</a></span></dt></dl></dd></dl></div></div><div class="navfooter"><hr><table width="100%" summary="Navigation footer"><tr><td width="40%" align="left"> </td><td width="20%" align="center"> </td><td width="40%" align="right"> <a accesskey="n" href="multi__preface.html">Next</a></td></tr><tr><td width="40%" align="left" valign="top"> </td><td width="20%" align="center"> </td><td width="40%" align="right" valign="top"> Part I. Preface</td></tr></table></div></body></html> |