单元测试 KafkaMessageListenerContainer

Question

是否可以对 KafkaMessageListenerContainer @Bean 进行单元测试？我想知道是否可以对我用来构建容器的代码进行单元测试。我正在尝试确保容器构建成功。

然而，当我直接对使用一组虚假的消费者属性执行此操作的函数进行单元测试时，我收到一条错误消息

Failed to Construct Kafka Consumer.... No resolvable bootstrap urls given in bootstrap.servers

这个错误让我相信这可能无法以这种方式进行测试。有没有另一种方法来测试这个，或者有没有办法实际构建 kafka 消息侦听器容器并通过单元测试验证它？

Answer 1

它正在尝试启动，但它没有关于要与哪个代理对话的配置（因为你的虚拟属性）。

您可以将其 autoStartup 属性 设置为 false 以防止 Spring 对它进行 start()。

您可以使用 属性 占位符，因此该值对于生产为 true，对于此测试为 false。