KafkaFetcherProvider extends ModuleProvider { @Override public ModuleConfig createConfigBeanIfAbsent() { return config; } KafkaFetcherProvider(); @Override String name(); @Override Class<? extends ModuleDefine> module(); @Override ModuleConfig createConfigBeanIfAbsent(); @Override void prepare(); @Override void start(); @Override void notifyAfterCompleted(); @Override String[] requiredModules();  }
@Test public void createConfigBeanIfAbsent() { ModuleConfig moduleConfig = provider.createConfigBeanIfAbsent(); assertTrue(moduleConfig instanceof KafkaFetcherConfig); }