We are pleased to announce the release of Spring Integration Kafka 1.2.

This new release provides a couple of major improvements and upgrades over the previous versions:

Support for Apache Kafka 0.8.2 and using the new Producer API;

Overhaul of the internal concurrent dispatching with a non-blocking ring buffer implementation based on Project Reactor.

For each of the changes, the goal was to improve the performance of the producer and, respectively, consumer components of Spring Integration Kafka. While we do not have any isolated benchmarks for Spring Integration Kafka proper, the enhancements of the release have contributed to the performance metrics reported in the newly released Spring XD 1.2.

By upgrading to Kafka 0.8.2, some of the options available in the old producer API (for example, sending messages synchronously) aren’t supported anymore, and some configuration options are semantically different (batch size, which previously referred to the message count, is now referring to the byte count). In the interest of clarity and reducing surprises, we’ve preferred to break backwards compatibility in the XML configuration, by removing unavailable options and renaming existing ones to make sure that they are fully understood. Consult the project for details.

Happy coding!

Some of the upcoming features will include:

Improving the documentation by creating a dedicated wiki;

Making it easy to send messages outside of a Spring Integration Kafka outbound channel adapter by providing template support;

Exploring the options for Reactive Streams integration.

SpringOne 2GX 2015 is around the corner!

Book your place at SpringOne2GX in Washington, DC soon. Early Bird Price expires August 14th! It’s simply the best opportunity to find out first hand all that’s going on and to provide direct feedback.

Discounts