docs: public Message decodeProtobufMessage(String topic, byte[] payload){
          Method parseMethod = allTopics ? messageParseMethodForAll : messageParseMethodByTopic.get(topic);
          try {
              return (Message) parseMethod.invoke(null, payload);
          } catch (IllegalArgumentException e) {
              throw new RuntimeException("Can't parse protobuf message, since parseMethod() is not callable. "
                      + "Please check your protobuf version (this code works with protobuf >= 2.6.1)", e);
          } catch (IllegalAccessException e) {
              throw new RuntimeException("Can't parse protobuf message, since parseMethod() is not accessible. "
                      + "Please check your protobuf version (this code works with protobuf >= 2.6.1)", e);
          } catch (InvocationTargetException e) {
              throw new RuntimeException("Error parsing protobuf message", e);
          }
      }