We are very pleased to announce the availability of the first milestone of the Spring for Apache Kafka 2.0 release 2.0.0.M1.
Significant new features in the 2.0 line include:
Support for timestamps in the
Seek to beginning/end of topics.
New threading model facilitated by KIP-62 - now that the consumer client does not rely on
poll()being called frequently, the threading model is much simpler; avoiding the need for internal
resume()processing. Listeners are now always invoked on the consumer thread. This, in turn, has facilitated:
BatchConsumerAwareMessageListener) are provided so that listener implementations can access the
Consumer<?, ?>object to perform operations such as
@KafkaListenerPOJO methods can now be annotated with
@SendToto send the method result to some other topic.