Spring for Apache Kafka 1.1.0 Milestone 2 Available
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:
-
The ability to process a batch of messages (introduced in the last milestone) is now available when using the
@KafkaListener
annotation, for example…@KafkaListener(id = "list", topics = "myTopic", containerFactory = "batchFactory") public void listen(List
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.
…