Spring For Apache Kafka 2.0 Milestone 3 Available
We are pleased to announce the availability of the Milestone 3 of the Spring for Apache Kafka 2.0
version.
It is available for download from the Milestone Repository:
repositories {
maven { url 'http://repo.spring.io/libs-milestone' }
}
compile "org.springframework.kafka:spring-kafka:2.0.0.M3"
Since the previous announcement, these feature have made it into the current Milestone:
-
Apache Kafka 0.11.0.0 client base line;
-
With the new Apache Kafka foundation we have introduced
KafkaTransactionManager
and transactions support in theKafkaTemplate
via newexecuteInTransaction()
operation; -
The
KafkaListenerContainer
can now be supplied with theTransactionManager
to perform polling and offset commits with transaction boundaries; -
The Kafka Headers support is provided as well. Now you can send and receive messages with any arbitrary headers, for example build request-reply scenarios using some
correlationKey
header; -
The
ConsumerAwareErrorHandler
is provided to manageConsumer
state in case of errors; -
The
KafkaEmbedded
can now be supplied with any arbitrarybrokerProperties
.
Thanks to all community members for any feedback and contributions!
General availability of the 2.0
release is expected to be in the September (shortly after the Spring Framework 5.0
release).
Feedback, feature requests and, of course, contributions are welcomed via the usual channels:
Project Page | Issues | Contributing | Help | Chat