public static JsonNode extractPayLoad()

in src/main/java/com/aliyun/odps/kafka/connect/utils/JsonHandler.java [22:33]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  public static JsonNode extractPayLoad(Schema schema, Object message, boolean schemaEnable) {
    Map<String, Boolean> props = Collections.singletonMap("schemas.enable", schemaEnable);
    final JsonConverter converter = new JsonConverter();
    converter.configure(props, false);
    JsonNode payload;
    try {
      payload = objectMapper.readTree(converter.fromConnectData("topic", schema, message));
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
    return payload;
  }