如何在Spring boot中运行bin/kafka-console-consumer.sh

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

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

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic")
    public void consume(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;

@SpringBootApplication
@EnableKafka
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}