spring boot 具体实现监听kafka topic的代码

以下是一个简单的Spring Boot应用程序，它使用Spring Kafka库监听Kafka主题：

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

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic", groupId = "my-group-id")
    public void consume(String message) {
        System.out.println("Received message: " + message);
    }

}

在上面的示例中，我们定义了一个名为`KafkaConsumer`的组件，并使用`@KafkaListener`注解来指定要监听的主题名称和消费者组ID。然后，我们定义了一个名为`consume`的方法来处理接收到的消息。在这个方法中，我们只是简单地将消息打印到控制台上。

要启动这个应用程序，您需要在`application.properties`文件中设置Kafka服务器的地址和端口号：

spring.kafka.bootstrap-servers=localhost:9092

注意，您也需要在`pom.xml`文件中添加Spring Kafka依赖项：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.7.3</version>
</dependency>

最后，您可以使用以下命令在命令行中启动应用程序：

mvn spring-boot:run

现在，您的应用程序应该已经开始监听名为`my-topic`的Kafka主题，并且可以接收和处理来自该主题的消息。