private String getMessageType()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java [122:129]

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

    private String getMessageType(ConsumerRecord<String, String> record) {
        Iterator<Header> headers = record.headers().headers(KafkaMessageInfo.KEY_MESSAGE_TYPE).iterator();
        if (!headers.hasNext()) {
            throw new MessagingException("Header " + KafkaMessageInfo.KEY_MESSAGE_TYPE + " missing.");
        }
        Header messageTypeHeader = headers.next();
        return new String(messageTypeHeader.value(), StandardCharsets.UTF_8);
    }