如何在spring boot中调用具有相同主题的两个Kafkalistener？

在Spring Boot中调用具有相同主题的两个KafkaListener可以通过以下步骤实现：

首先，确保已经在Spring Boot项目中添加了Kafka依赖。可以在pom.xml文件中添加以下依赖项：

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

创建一个Kafka配置类，用于配置Kafka的连接信息和其他属性。可以使用@Configuration注解标记该类，并使用@EnableKafka注解启用Kafka支持。在配置类中，可以配置Kafka的连接地址、序列化器、消费者组等信息。例如：

@Configuration
@EnableKafka
public class KafkaConfig {

    @Value("${spring.kafka.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public Map<String, Object> consumerConfigs() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "group1");
        return props;
    }

    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        return new DefaultKafkaConsumerFactory<>(consumerConfigs());
    }

    @Bean
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }
}

创建两个KafkaListener，分别处理相同主题的消息。可以使用@KafkaListener注解标记方法，并指定要监听的主题。例如：

@Component
public class KafkaListener1 {

    @KafkaListener(topics = "topic1")
    public void listen1(String message) {
        // 处理消息
        System.out.println("Listener 1: " + message);
    }
}

@Component
public class KafkaListener2 {

    @KafkaListener(topics = "topic1")
    public void listen2(String message) {
        // 处理消息
        System.out.println("Listener 2: " + message);
    }
}

在上述示例中，KafkaListener1和KafkaListener2分别监听名为"topic1"的主题。

在Spring Boot应用程序的入口类上添加@SpringBootApplication注解，并在main方法中运行应用程序。例如：

@SpringBootApplication
public class Application {

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