public static BinaryMessageDecoder<Wikipedia> getDecoder() {
    return DECODER;
  }
Return the BinaryMessageDecoder instance used by this class.
itests/qtest-druid/src/main/java/org/apache/hive/kafka/Wikipedia.java