什么是Kafka监听器”

Kafka监听器是一种连接Kafka的客户端组件，用于接收和处理消息。在Spring Boot中，可以使用KafkaListener注解来创建一个Kafka监听器。

以下是一个简单的示例，展示如何使用KafkaListener注解并监听具有特定主题的消息：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class MyListener {

    @KafkaListener(topics = "myTopic", groupId = "myGroup")
    public void listen(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的示例中，MyListener类上使用了@Component注解，使得Spring Boot可以将其识别为一个组件。然后，@KafkaListener注解被用于listen()方法上，指定监听的主题为myTopic，所属的组为myGroup。当Kafka Broker将消息写入主题myTopic时，该方法会自动被触发，接收并处理消息。

注意，使用KafkaListener注解时需要在Spring Boot应用程序的配置文件中指定Kafka Broker的连接信息和属性。