private Class<? extends Decoder<U>> updateDecoderClass;
private ConsumerConnector consumer;
private ServingModelManager<U> modelManager;
private TopicProducer<K,M> inputProducer;
@SuppressWarnings("unchecked")
<BUG>public void init(ServletContext context) {
String serializedConfig = context.getInitParameter(ConfigUtils.class.getName() + ".serialized");</BUG>
Objects.requireNonNull(serializedConfig);
this.config = ConfigUtils.deserialize(serializedConfig);
this.updateTopic = config.getString("oryx.update-topic.message.topic");

private Class<? extends Decoder<U>> updateDecoderClass;
private ConsumerConnector consumer;
private ServingModelManager<U> modelManager;
private TopicProducer<K,M> inputProducer;
@SuppressWarnings("unchecked")
void init(ServletContext context) {
String serializedConfig = context.getInitParameter(ConfigUtils.class.getName() + ".serialized");
Objects.requireNonNull(serializedConfig);
this.config = ConfigUtils.deserialize(serializedConfig);
this.updateTopic = config.getString("oryx.update-topic.message.topic");
