java - 单元测试 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。