为Spring Kafka配置类编写junit测试?

brgchamk  于 12个月前  发布在  Spring
关注(0)|答案(1)|浏览(123)

我为我的Kafka消费者提供了如下配置类

@Configuration
@EnableKafka
@AllArgsConstructor(onConstructor = @__(@Autowired))
public class ConsumerConfig{
   //some fields
   private Map<String, Object> getConfig(){
      //some kafka config in a map
      return map;
   }

   @Bean("consumerFactory")
   public ConsumerFactory<String, SomeClass> consumerFactory() {
      return new DefaultKafkaConsumerFactory<>(this.getConfig());
   }
}

字符串
我尝试了一些通过模拟一些属性的测试,但所有的测试似乎都失败了。有没有什么方法可以通过模拟属性来创建这个ConsumerFactory bean?

knpiaxh1

knpiaxh11#

在项目的测试套件中有很多使用模拟消费者的例子。
或者,考虑使用kafka-clients库提供的MockConsumer
从版本3.0.7开始,Spring提供了一个MockConsumerFactory来提供MockConsumer s。对于早期版本,您必须模拟工厂。

相关问题