如何检查@KafkaListener是否在联调中被调用？

Question

我想为整个Kafka流编写一个集成测试。

在我的生产代码中，我有：

@KafkaListener(topics = "myTopic")
public void listen(@Payload String payload) {
    log.debug("processing payload: '{}' ", payload);
    // business logic here
}

在我的测试代码中，我使用KafkaProducer

我希望有一个钩子，表明调用了KafkaListener。我可以在测试中加入一些延迟，但这是一个糟糕的做法，我想避免它。

有没有更好的方法来等待正在处理的@KafkaListener？

Answer 1

如果您的侦听器调用某个服务，您可以为该服务注入一个模拟并验证它是否被调用。

此外，您可以在测试用例中封装侦听器，并添加倒计时闩锁。

有关示例，请参阅此答案。