private Iterable getRecordHeaders()

in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java [217:233]

• 17 lines of code
• 6 McCabe index (conditional complexity)

  private Iterable<? extends Header> getRecordHeaders(SinkRecord record) {
    ConnectHeaders headers = new ConnectHeaders();
    if(record.headers() != null) {
      int headerCount = 0;
      for (Header header : record.headers()) {
        if (header.key().getBytes().length < 257 &&
            String.valueOf(header.value()).getBytes().length < 1025) {
          headers.add(header);
          headerCount++;
        }
        if (headerCount > 100) {
          break;
        }
      }
    }
    return headers;
  }