Why Spring

Overview Microservices Reactive Event Driven Cloud Web Applications Serverless Batch

Learn

Overview Quickstart Guides Blog

Projects

Overview Spring Boot Spring Framework Spring Cloud Spring Cloud Data Flow Spring Data Spring Integration Spring Batch Spring Security View all projects Spring Tools 4 Spring Initializr

Academy

Courses Get Certified

Solutions

Overview Spring Runtime Spring Consulting Spring Academy For Teams Security Advisories

Community

Overview Events Team

light

Spring for Apache Kafka 3.1.10-SNAPSHOT

Edit this Page Github Project Stack Overflow

Spring for Apache Kafka
Reference
Using Spring for Apache Kafka
Receiving Messages

Receiving Messages

You can receive messages by configuring a MessageListenerContainer and providing a message listener or by using the @KafkaListener annotation.

Section Summary

Message Listeners
Message Listener Containers
Manually Committing Offsets
@KafkaListener Annotation
Obtaining the Consumer group.id
Container Thread Naming
@KafkaListener as a Meta Annotation
@KafkaListener on a Class
@KafkaListener Attribute Modification
@KafkaListener Lifecycle Management
@KafkaListener @Payload Validation
Rebalancing Listeners
Enforcing Consumer Rebalance
Forwarding Listener Results using @SendTo
Filtering Messages
Retrying Deliveries
Starting @KafkaListeners in Sequence
Using KafkaTemplate to Receive

Sending Messages Message Listeners

Spring for Apache Kafka
- 3.1.10-SNAPSHOTcurrent

Related Spring Documentation
- Spring Framework
- Spring Data
  - Spring Data Commons
  - Spring Data JPA
- Spring Integration
- Spring Security
- Spring AI
- Spring CLI
- Spring GraphQL
- Spring Shell

© VMware, Inc. or its affiliates. Terms of Use • Privacy • Trademark Guidelines • Thank you • Your California Privacy Rights • Cookie Settings

Apache®, Apache Tomcat®, Apache Kafka®, Apache Cassandra™, and Apache Geode™ are trademarks or registered trademarks of the Apache Software Foundation in the United States and/or other countries. Java™, Java™ SE, Java™ EE, and OpenJDK™ are trademarks of Oracle and/or its affiliates. Kubernetes® is a registered trademark of the Linux Foundation in the United States and other countries. Linux® is the registered trademark of Linus Torvalds in the United States and other countries. Windows® and Microsoft® Azure are registered trademarks of Microsoft Corporation. “AWS” and “Amazon Web Services” are trademarks or registered trademarks of Amazon.com Inc. or its affiliates. All other trademarks and copyrights are property of their respective owners and are only mentioned for informative purposes. Other names may be trademarks of their respective owners.