我为我的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?
1条答案
按热度按时间knpiaxh11#
在项目的测试套件中有很多使用模拟消费者的例子。
或者,考虑使用
kafka-clients
库提供的MockConsumer
。从版本3.0.7开始,Spring提供了一个
MockConsumerFactory
来提供MockConsumer
s。对于早期版本,您必须模拟工厂。