I am pleased to announce that the Spring for Apache Kafka 1.1.0.M1 milestone release is available now.

As usual, thanks to the community for any feedback and contribution as always!

Highlights of this release:

• Support for the 0.10.x.x client (use 1.0.x for the 0.9.x.x client)

• Support for listeners that receive the entire batch of messages returned by the consumer.poll() operation

• Support for null payloads - used to delete keys when using log compaction

• Allow setting the initial offset to be relative to the current offset

Project Page | GitHub | Help | Documentation