Hot on the heels of the recent Apache Kafka 2.4.0 release, I am pleased to announce the release candidate for Spring for Apache Kafka 2.4 - 2.4.0.RC1 - is available in the Spring milestone repository. This version is essentially functionally equivalent to 2.3.x, but is compiled against the 2.4.0 kafka-clients and supports the new incremental rebalancing protocol. The 2.4.0 kafka clients are not binary compatible with Spring for Apache Kafka 2.3 so if you wish to use the 2.4.0 clients, you must upgrade to this version. See the appendix in the reference manual for how to override the jar…

We are pleased to announce the following releases are now available. All users are encouraged to upgrade to these versions 2.3.0.RELEASE (new) 2.2.9.RELEASE (maintenance) The 2.3.0 release is the first release of the newest line for this project. Refer to the What’s New chapter for more information, but here are a few highlights: Producing Option to use a producer per thread, to avoid blocking other threads when flushing. The AggregatingReplyingKafkaTemplate extension to the ReplyingKafkaTemplate is provided to aggregate replies from multiple consumers. Consuming You can now add a…

We are pleased to announce the following maintenance releases are now available. All users are encouraged to upgrade to these versions 2.2.0.RELEASE (new). 2.1.8.RELEASE (maintenance). The 2.2.0 release is the first release of the newest line for this project. What’s New chapter for more information, but here are a few highlights: Micrometer Timer s are now supported to monitor listener performance. @RabbitListener s can now receive a batch of messages in a List, batches can either be created on the producer side, or a SimpleMessageListenerContainer can create a batch from incoming discrete…

We are pleased to announce the following maintenance releases are now available. All users are encouraged to upgrade to these versions Spring Integration 5.1.7.RELEASE 5.0.14.RELEASE 4.3.21.RELEASE Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter Spring AMQP (Spring for RabbitMQ) 2.1.8.RELEASE. 2.0.13.RELEASE. 1.7.14.RELEASE. Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter Spring for Apache Kafka 2.2.8.RELEASE 2.1.13.RELEASE 1.3.10.RELEASE Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter In addition, milestone 4 (and the…

We are pleased to announce the availability of the second milestone of the Spring for Apache Kafka 2.3 release - 2.3.0.M2. Highlights SeekToCurrentErrorHandler can be configured to not retry certain exceptions. The new RecoveringDeserializationExceptionHandler can recover from failed deserialization operations in Kafka Streams applications, for example to send the failed message to a dead-letter topic. The new HeaderEnricher transformer can be added to a Kafka Streams topology to add headers. The new MessagingTransformer can be used to invoke a Spring Integration flow within a Kafka Streams…

We are pleased to announce the availability of the second milestone of the Spring AMQP 2.2 release - 2.2.0.M2. Highlights Spring Data "Projection Interfaces" are now supported by the Jackson message converter. @RabbitListener methods can now receive batched messages as a List instead of one-at-a-time. You can now override the default acknowledge mode and executor directly on the @RabbitListener annotation. For more information, see the What’s New chapter and the change logs. Change log for M1. Change log for M2. Project Page | GitHub | JIRA | Documentation | Stack Overflow | Gitter

I am pleased to announce that Spring for Apache Kafka 2.2.0.RELEASE is now available. While the 2.1.x release is compatible with the 2.0.0 kafka-clients jar, (since 2.1.9), this version requires 2.0.0 (and provides a 2.0.0 embedded broker for testing). Highlights The SeekToCurrentErrorHandler can now "skip" records that fail repeatedly Such "skipped" records can be published to a dead-letter topic (or otherwise disposed of by application code) Headers are added with diagnostics about the failure When using transactions, the same functionality can be achieved with the default…

We are pleased to announce the following maintenance releases are now available. All users are encouraged to upgrade to these versions Spring Integration 5.0.7.RELEASE Project Page | GitHub | JIRA | Documentation | Stack Overflow | Gitter Spring AMQP (Spring for RabbitMQ) 2.0.5.RELEASE. 1.7.9.RELEASE. Project Page | GitHub | JIRA | Documentation | Stack Overflow | Gitter Spring for Apache Kafka 2.1.8.RELEASE 1.3.6.RELEASE Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter In addition, the first milestones of the next generations are also available: Spring Integration 5.…

This is the second blog in a series of pre-release blogs in preparation for Spring Cloud Stream 2.0.0.RELEASE. Preface Spring Cloud Stream 2.0 introduces polled consumers, where the application can control message processing rates. Introduction Spring Cloud Stream has the concepts of producers and consumers; when using the messaging paradigm, MessageChannels are bound to destinations (e.g. Kafka topics, Rabbit Exchanges/Queues). To-date, on the consumer side, messages are delivered whenever an idle consumer is available. In effect, the broker controls the rate of delivery; usually, the next…

I am pleased to announce that Spring for Apache Kafka 2.1.3.RELEASE is available. In addition, the Spring Integration extension spring-integration-kafka 3.0.2.RELEASE is also available. While these are point releases in the 2.1.x (and 3.0.x) lines; they introduce some important new features: Spring for Apache Kafka Change Log Request/Reply messaging with the ReplyingKafkaTemplate pause/resume on listener containers default @KafkaHandler method for multi-method @KafkaListener ChainedKafkaTransactionManager to improve transaction synchronization scenarios Spring Integration Kafka Change Log…