public KafkaMessageInfo()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java [40:46]

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

    public KafkaMessageInfo(ConsumerRecord<String, ?> record, Map<String, String> props) {
        this.props = props;
        this.topic = record.topic();
        this.partition = record.partition();
        this.offset = record.offset();
        this.createTime = record.timestamp();
    }