Spring
AI
Spring AI
Java
Quarkus Spring Spring Data Spring Cloud Hibernate
Python
Database
Postgresql Mysql
Spring Kafka 中文文档
    • Overview
    • What’s new?
    • Introduction
      • Quick Tour
    • Reference
      • Using Spring for Apache Kafka
        • Connecting to Kafka
        • Configuring Topics
        • Sending Messages
        • Receiving Messages
          • Message Listeners
          • Message Listener Containers
          • Manually Committing Offsets
          • Asynchronous @KafkaListener Return Types
          • @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 `@KafkaListener`s in Sequence
          • Using KafkaTemplate to Receive
        • 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
      • Non-Blocking Retries
        • How the Pattern Works
        • Back Off Delay Precision
        • Configuration
        • Programmatic Construction
        • Features
        • Combining Blocking and Non-Blocking Retries
        • Accessing Delivery Attempts
        • Topic Naming
        • Multiple Listeners, Same Topic(s)
        • DLT Strategies
        • Specifying a ListenerContainerFactory
        • Accessing Topics' Information at Runtime
        • Changing KafkaBackOffException Logging Level
      • Apache Kafka Streams Support
      • Testing Applications
    • Tips, Tricks and Examples
    • Other Resources
    • Override Spring Boot Dependencies
    • Micrometer Observation Documentation
    • Native Images
    • Change History
  • Spring Kafka 中文文档
  • Reference
  • Using Spring for Apache Kafka
  • Receiving Messages

Receiving Messages

你可以通过配置 MessageListenerContainer 并提供消息侦听器或使用 @KafkaListener 注释来接收消息。

粤ICP备2024239452号-1