Kafka事件监听器在SpringBootTest中不能正常工作。

要解决“Kafka事件监听器在SpringBootTest中不能正常工作”的问题，可以按照以下步骤进行：

1. 确保Kafka配置正确，包括Kafka服务器地址、端口号、Topic名称等。可以在application.properties或application.yml文件中配置。

2. 在测试类中添加以下注解，以确保Spring Boot测试上下文正确加载Kafka配置：

@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka // 添加此注解以创建嵌入式Kafka服务器
public class KafkaEventListenerTest {

    // 添加KafkaTemplate bean
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    // 添加EmbeddedKafkaBroker bean
    @Autowired
    private EmbeddedKafkaBroker embeddedKafkaBroker;

    // 添加事件监听器
    @Autowired
    private KafkaEventListener kafkaEventListener;

    // 添加测试方法
    @Test
    public void testKafkaEventListener() {
        // 发送测试消息
        kafkaTemplate.send("test-topic", "test-message");

        // 等待一段时间以确保监听器有足够的时间处理消息
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 添加断言以验证监听器是否正常工作
        // ...
    }
}

3. 在Kafka事件监听器的实现类中，确保监听器注解正确配置。例如：

@Component
public class KafkaEventListener {

    // 添加KafkaListener注解，指定要监听的Topic
    @KafkaListener(topics = "test-topic")
    public void listen(ConsumerRecord<String, String> record) {
        // 处理接收到的消息
        String message = record.value();
        System.out.println("Received message: " + message);
    }
}

通过以上步骤，你可以在Spring Boot测试中正确运行Kafka事件监听器，并进行验证。请根据你的实际需求进行适当的修改和调整。