private static void mapHeader()

in core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java [239:251]

• 12 lines of code
• 5 McCabe index (conditional complexity)

    private static void mapHeader(Header header, String prefix, Map<String, Object> destination) {
        final String key = StringHelper.after(header.key(), prefix, header.key());
        final Schema schema = header.schema();

        if (schema != null
                && schema.type().equals(Schema.BYTES_SCHEMA.type())
                && Objects.equals(schema.name(), Decimal.LOGICAL_NAME)
                && header.value() instanceof byte[]) {
            destination.put(key, Decimal.toLogical(schema, (byte[]) header.value()));
        } else {
            destination.put(key, header.value());
        }
    }