Spring Cloud Stream Fishtown.M1 /2.1.0.M1 Release Announcement

We are pleased to announce the first Milestone of the Spring Cloud Stream Fishtown release train - Fishtown.M1/2.1.0.M1.

Spring Cloud Stream Fishtown 2.1.0.M1 is available for use in the Spring Milestone repository. The release notes include relevant information about version compatibility with Spring Boot, Spring Cloud, Spring AMQP, and Spring for Apache Kafka.

The following section provides a brief summary of features and improvements included in this release.

Notable Features, Improvements & enhancements

Core

• Support for Message Listener container customization by simply registering implementation of ListenerContainerCustomizer bean.

• Binding properties precedence support. This feature allows default binding properties to be overriden with specific binding properties. For example.

  spring.cloud.stream.default.contentType=text/plain
  spring.cloud.stream.default.producer.partitionCount=1
  spring.cloud.stream.bindings.output.producer.partitionCount=4
  

  In the above, the default content type for all bindings is set to text/plain. Also, all producer bindings partitionCount is set to 1 with the exception of output destination bindings where it is set to 4
• In addition to the existing input binding actuator endpoints, support for output binding actuator endpoints was added as well.

Rabbit Binder

• Exposed support for setting queue length as and overflow policy
• Multiplex support

Kafka Binder

• Wild cards are now supported in kafka topic names in the binder [kafka binder]
• New annotation KafkaStreamsStateStore for creating state stores in lower level processor API in kafka streams [kafka streams binder]
• Removing the creation of unnecessary repartition topics in the kafka streams binder
• Consuming from multiple topics in kafka streams binder
• Improvements in in interactive query support in kafka streams binder - Multiple consumers and querying across them are now supported.
• QueryableStoreRegistry is deprecated and a new API is provided called InteractiveQueryService. In addition to provide ability to query state stores, this API also gives information about the host where the consumer is running.
• Multiplex support

Various other enhancements and bug fixes

Once again huge thanks to all the community contributors!!!

NOTE:
If the applications are created from Spring Initializr, they need to add this BOM snippet in maven dependency management before the spring-cloud BOM declaration:

<dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-stream-dependencies</artifactId>
           <version>Fishtown.M1</version>
           <type>pom</type>
           <scope>import</scope>
</dependency>

Next Steps

The M2 is planned for the end of July and will contain primarily new binding features as well as integration with Spring Cloud Function

As always, we welcome feedback and contributions, so please reach out to us on Stackoverflow or GitHub or via Gitter.