private static KafkaPosition asKafkaPosition()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [218:223]

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

    private static KafkaPosition asKafkaPosition(Position position) {
        if (! KafkaPosition.class.isInstance(position)) {
            throw new IllegalArgumentException(format("Position %s must be and instance of %s", position, KafkaPosition.class.getCanonicalName()));
        }
        return (KafkaPosition) position;
    }