Spring for Apache Kafka 1.1.0 Milestone 2 Available

DZone 's Guide to

Spring for Apache Kafka 1.1.0 Milestone 2 Available

Spring for Apache Kafka has released its latest milestone, 1.1.0.M2! Come find out how to get it and what it makes available!

· Java Zone ·
Free Resource

I am pleased to announce that the second milestone for Spring for Apache Kafka version 1.1.0.M2 is now available in the spring milestone repo.

This includes some bug fixes and the following new features:

@KafkaListener(id = "list", topics = "myTopic",
                          containerFactory = "batchFactory")
public void listen(List<String> list) {
  • You can now perform seek operations from the listener — this allows setting an initial offset when partitions are assigned by Kafka when using group management. You can also perform arbitrary seek operations after initialization.

The KafkaTemplate now provides access to the metrics and partitionsFor methods on the Producer.

In addition, the first milestone of spring-integration-kafka version 2.1 is now available, utilizing the spring-kafka 1.1.0.M2 version. It also supports batch payloads.

See the project page for links to documentation and more information.

apache, kafka, release, spring, version

Published at DZone with permission of Gary Russell . See the original article here.

Opinions expressed by DZone contributors are their own.

{{ parent.title || parent.header.title}}

{{ parent.tldr }}

{{ parent.urlSource.name }}