docs: public Message decodeProtobufOrJsonMessage(String topic, byte[] payload) {
          try {
              if (shouldDecodeFromJsonMessage(topic)) {
                  return decodeJsonMessage(topic, payload);
              }
          } catch (InvalidProtocolBufferException e) {
              //When trimming files, the Uploader will read and then decode messages in protobuf format
              LOG.debug("Unable to translate JSON string {} to protobuf message", new String(payload, Charsets.UTF_8));
          }
          return decodeProtobufMessage(topic, payload);
      }