如何在 Spring Boot 3.X 中使用 Kafka 实现消息传递功能？

package com.zs.kafka.demo1.config; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; /** * @author 未来码匠 */ @Component public class KafkaConfig { /** * 当Apache Kafka基础设施存在时，任何bean都可以用@KafkaListener进行注释，以创建侦听器端点。 * 如果没有定义KafkaListenerContainerFactory，则会使用spring.kafka.listener.*中定义的密钥自动配置默认的KafkaListerContainerFactory。 * 根据指定的主题名topic1来创建一个侦听器端点 * 语法格式：@KafkaListener(id = "指定的ID属性名", topics = "指定的主题名称") * id: 此容器的唯一标识符。如果未指定任何id，则使用自动生成的id。 * 注意：提供此值时，将覆盖消费者工厂配置中的group id属性，除非设置idIsGroup()为false或被提供的groupId()。支持SpEL#｛…｝和属性占位符$｛…}。 * topics: 此侦听器的主题。此主题可能是"主题名称"、"属性占位符键"或"表达式"。 * 表达式必须解析为主题名称。这使用了组管理，Kafka会将分区分配给组成员。与topicPattern（）和topicPartitions（）互斥。 */ @KafkaListener(id = "sampleListener", topics = "topic1") void listenForTopic(String payload) { System.out.println("获取内容: " + payload); } }