public void accept()

in src/main/java/org/apache/sling/distribution/journal/kafka/JsonRecordHandler.java [43:48]

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

    public void accept(ConsumerRecord<String, String> record) throws IOException {
        MessageInfo info = new KafkaMessageInfo(record);
        String payload = record.value();
        T message = reader.readValue(payload);
        handler.handle(info, message);
    }