private ArrayNode createHeaderArray()

in src/main/java/software/amazon/event/kafkaconnector/mapping/SinkRecordJsonMapper.java [64:77]

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

  private ArrayNode createHeaderArray(SinkRecord sinkRecord) throws IOException {
    var headersArray = objectMapper.createArrayNode();

    for (Header header : sinkRecord.headers()) {
      var headerItem = objectMapper.createObjectNode();
      headerItem.set(
          header.key(),
          createJSONFromByteArray(
              jsonConverter.fromConnectHeader(
                  sinkRecord.topic(), header.key(), header.schema(), header.value())));
      headersArray.add(headerItem);
    }
    return headersArray;
  }