private Received toReceived()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaSubscription.java [80:83]

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

    private Received toReceived(ConsumerRecord<String, byte[]> record) {
        Position position = new KafkaPosition(record.partition(), record.offset());
        return new Received(position, toMessage(record));
    }