For the latest stable version, please use Spring for Apache Kafka 3.3.0!

Using Spring for Apache Kafka

This section offers detailed explanations of the various concerns that impact using Spring for Apache Kafka. For a quick but less detailed introduction, see Quick Tour.

Section Summary

Connecting to Kafka
Configuring Topics
Sending Messages
Receiving Messages
Listener Container Properties
Dynamically Creating Containers
Application Events
Topic/Partition Initial Offset
Seeking to a Specific Offset
Container factory
Thread Safety
Monitoring
Transactions
Exactly Once Semantics
Wiring Spring Beans into Producer/Consumer Interceptors
Producer Interceptor Managed in Spring
Pausing and Resuming Listener Containers
Pausing and Resuming Partitions on Listener Containers
Serialization, Deserialization, and Message Conversion
Message Headers
Null Payloads and Log Compaction of 'Tombstone' Records
Handling Exceptions
JAAS and Kerberos