We are pleased to announce the first Release Candidate for the version 2.1 of the Spring for Apache Kafka: The general reason for so quick point release is the recently released Apache Kafka 1.0.0 version. There are no critical feature in that release, but some breaking changes in the kafka.admin and kafka.streams have been introduced. Therefore this release represents mostly compatibility with Apache Kafka 1.0.0: Deprecate bounce() and waitUntilSynced() in the KafkaEmbedded since respective API in the AdminUtils have been removed The KStreamBuilderFactoryBean now uses StreamsBuilder instead…

On behalf of the Spring Integration team I am pleased to announce that the Release Candidate 1 for the Spring Integration 5.0 version (5.0.0.RC1) is now available. It can be downloaded from the Milestone Repository: 20 JIRAs (and some GitHub issues) are included in this release, together with bug fixes and a number of new features. Some highlights of features in the RC1, since the previously announced Milestone 7: The components populated by the Java DSL parser are now registered as BeanDefinitions in the application context, thanks to newly introduced in the Spring Framework 5.0 Supplier…

Dear Spring Community! As an event-driven microservices framework, Spring Cloud Stream dramatically simplifies the complexity while developing event-driven applications. The feature capabilities and its benefits are not the focus of this article (to learn more, please review the Reference Guide), but instead, my goal is to show you what the framework has to offer from the testing standpoint, the tools, and techniques. This article is intended to encourage the community to share feedback on the existing testing infrastructure, so any thoughts, comments, or feature requests are welcome! We…

Dear Spring Community! Today I’d like to announce the first Release Candidate of the version 1.1 of Spring Integration for Amazon Web Services. Its artifact is available in the Milestone Repository. Thanks to everybody contributed! Some highlights of the features since the previously announced Milestone 1: KinesisMessageDrivenChannelAdapter The KinesisMessageDrivenChannelAdapter has been improved to handle properly expired and throttled shard iterators. Also it now skips closed shards. Some other bug fixed have been provided after early community adoption. DynamoDbMetaDataStore The…

I am pleased to announce that the 2.0.0.RELEASE of Spring AMQP is now available in the Spring release repository and Maven Central. First of all thanks to all community members for any feedback and contributions to make this new instalment of Spring for AMQP and RabbitMQ support project! Some highlights what we have after a year and a couple months of amazing team work: Full Java 8 and Spring Framework 5.0 support; New spring-rabbit-junit artifact with some useful testing utilities including BrokerRunning JUnit @Rule; The amqp-client library of version 5.0; A DirectMessageListenerContainer to…

We are pleased to announce the general availability of the 2.0.0.RELEASE of the Spring for Apache Kafka 2.0 version. As mentioned in the 2.0 RC1 announcement, the 1.3 GA is also available supporting the Kafka 0.11.x.x client with Spring Framework 4.3.x applications. They are available for download from the Release Repository and Maven Central: That was 6 months journey to bring a Java 8 and Spring Framework 5 vision for Spring for Apache Kafka project and here is what we have so far overall: Apache Kafka 0.11.x.x client Transactions support Headers mapping Kafka Streams support KafkaAdmin is…

On behalf of the Spring Integration team I am pleased to announce that the Milestone 7 for the Spring Integration 5.0 version (5.0.0.M7) is now available. It is available for download from the Milestone Repository: 21 JIRAs (and some GitHub issues) made into this release, including bug fixes and a number of new features. Some highlights of features in the M7, since the previously announced Milestone 6: Reactive WebFlux Channel Adapters has been extracted to the separate spring-integration-webflux module to distinguish Servlet-based MVC configuration from the Reactive foundation. The…

We are pleased to announce the availability of the Milestone 2 of the Spring for Apache Kafka 1.3 version. It is available for download from the Milestone Repository: (Milestone 1 had a blocker issue). Functionally, the 1.3.x line provides a subset of the 2.0 line (which requires Spring Framework 5.0 and Java 8), but provides support for Java 7 projects and Spring Framework 4.3.x. It is primarily intended to provide early access to 0.11.0.0 Apache Kafka client features, but here is a summary: Apache Kafka 0.11.0.0 client; Improved listener container threading model facilitated by KIP-62; With…

On behalf of the Spring Integration team I am pleased to announce that the Milestone 6 for the Spring Integration 5.0 version (5.0.0.M6) is now available. It is available for download from the Milestone Repository: 19 JIRAs (and some GitHub issues) made into this release, including bug fixes and a number of new features. Some highlights of features in the M6, since the previously announced Milestone 5: The Spring WebFlux based Reactive Channel Adapters are provided for the HTTP server side: @Bean public IntegrationFlow sseFlow() { return IntegrationFlows .from(Http.inboundReactiveGateway("/sse…

I am pleased to announce that the Milestone 5 of Spring AMQP 2.0 is now available in the Spring milestone repository. Features and fixes since the last milestone: Log4j2 AmqpAppender is now thread-safe; DefaultMessagePropertiesConverter now correctly passes arrays for the header values to the AMQP Client library; Jackson2JsonMessageConverter can now be configured for the trustedPackages to fix violation for Jackson Serialization Gadgets; RabbitAdmin operations can now be performed on the same AMQP channel as a unit of work via RabbitTemplate.invoke(); PossibleAuthenticationFailureException can…