import com.cloudera.oryx.common.settings.ConfigUtils;
import com.cloudera.oryx.kafka.util.KafkaUtils;
@WebListener
public final class ModelManagerListener<K,M,U> implements ServletContextListener, Closeable {
private static final Logger log = LoggerFactory.getLogger(ModelManagerListener.class);
<BUG>public static final String MANAGER_KEY = ModelManagerListener.class.getName() + ".ModelManager";
public static final String INPUT_PRODUCER_KEY =
ModelManagerListener.class.getName() + ".InputProducer";</BUG>
private Config config;
private String updateTopic;

import com.cloudera.oryx.common.settings.ConfigUtils;
import com.cloudera.oryx.kafka.util.KafkaUtils;
@WebListener
public final class ModelManagerListener<K,M,U> implements ServletContextListener, Closeable {
private static final Logger log = LoggerFactory.getLogger(ModelManagerListener.class);
static final String MANAGER_KEY = ModelManagerListener.class.getName() + ".ModelManager";
static final String INPUT_PRODUCER_KEY = ModelManagerListener.class.getName() + ".InputProducer";
private Config config;
private String updateTopic;
