<BUG>public Decode createDecoder() {String codec = (String) this.config.get("codec");if (codec != null && codec.equalsIgnoreCase("plain")) {return new PlainDecoder();} else {return new JsonDecoder();}}</BUG><CONTEXT>return bo;}).collect(Collectors.toList());this.registerShutdownHook(outputProcessors);return outputProcessors;}<extra_id_0>public void shutdown() {</CONTEXT>
[DELETED]