Spring Cloud Stream Chelsea.RC1 Release Notes

Release Train Components and Versions

Spring Boot compatibility

This release is based on Spring Boot 1.5. It is also compatible with Spring Boot 1.4.4.RELEASE and later.

Spring Cloud integration

This release is also part of the Spring Cloud Dalston release train.

Middleware compatibility

• RabbitMQ: See Spring AMQP 1.7.1 reference documentation for details
• Apache Kafka: 0.10.1 with default dependency set, as well as 0.9, 0.10.0 via client library override - see reference documentation for details

Issues resolved

Spring Cloud Stream Core

497 : Deserialization errors (e.g. w/Kryo) should be logged more explicitly
631 : PartitionKeyExtractorStrategy instances do not have access to application context
682 : Support of Multiple @StreamListener methods on the same bound element
710 : Document dynamic destinations
737 : AggregateApplicationBuilder forcing full auto-config
745 : Separate binding from queue provisioning and introduce provisioning SPI
759 : Performance issue with aggregated app
764 : org.springframework.cloud.stream.binding.MessageConverterConfigurer$PartitioningInterceptor Performance
772 : Register PartitionKeyExtractorStrategy Instance Failed
773 : Wrong channel injection example
774 : MessageConverter fails to convert files to string
785 : Improve aggregation documentation
793 : TupleJsonMessageConverter must recognize inbound application/json payloads
797 : Improve the content type and transformation section of the documentation
803 : Making provisioning provider protected in AbstractMessageChannelBinder
810 : Regression when BindingProperties are manipulated programmatically
812 : AbstractMessageChannelBinder may fail with null headersToEmbed
816 : Regression when binding channels in aggregate applications
818 : Binding service properties for aggregate child application are not used when binding
819 : Sources that @Autowire Source Cannot be Aggregated
820 : Add documentation for @StreamListener with conditions
828 : Add doc for Schema Server GET request '/schema/format' endpoint
832 : Improve caching capabilities of Schemas
841 : Meta-annotated @StreamListener has empty attributes
844 : Regression when checking declarative methods when argument type is 'Object'

Spring Cloud Stream Binder Rabbit

9 : Replace request/reply headers with 'headers' property
16 : Clarify that when multiple binders are used, autoconfiguration needs to be disabled
23 : There is no option to configure the consumer queue
24 : Allow setting TTL on queues
26 : Support for Rabbitmq delayed queue
34 : Don't Bind An Existing Queue
40 : Separate binding from queue provisioning
43 : Fix Incorrect routingKeyExpression When Stream is Partitioned
48 : Binder Incorrectly Creates non-Durable Exchanges

Spring Cloud Stream Binder Kafka

21 : Document how to re-process messages from DLQ
48 : Documentation doesn't explain how startOffsets works for anon groups
50 : Kafka DLQ partitioning should match partition specifics of the original topic
52 : Lots of obsolete logging when perfoming health checks
56 : Set default log levels for Zookeeper client (on the Kafka binder) to ERROR
73 : Support Boot 1.5 configuration properties for Kafka
79 : KafkaBinderHealthIndicator doesn't work with SSL
81 : Test the binder implementation with different kafka releases
83 : Sporadic TopicExistsException at start with 0.10.1.1 cluster
85 : spring-integration-kafka included twice
86 : Separate binding from queue provisioning
88 : Starting with 1.2, starter baseline should be Kafka 0.10.1
102 : Reinstate spring-cloud-stream-binder-kafka-test-support artifact
104 : JUnit dependency should be excluded