Over a million developers have joined DZone.
{{announcement.body}}
{{announcement.title}}

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

Verify, standardize, and correct the Big 4 + more– name, email, phone and global addresses – try our Data Quality APIs now at Melissa Developer Portal!

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.

Developers! Quickly and easily gain access to the tools and information you need! Explore, test and combine our data quality APIs at Melissa Developer Portal – home to tools that save time and boost revenue. Our APIs verify, standardize, and correct the Big 4 + more – name, email, phone and global addresses – to ensure accurate delivery, prevent blacklisting and identify risks in real-time.

Topics:
spring ,kafka ,apache ,version ,release

Published at DZone with permission of

Opinions expressed by DZone contributors are their own.

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

{{ parent.tldr }}

{{ parent.urlSource.name }}