public String generateId()

in src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/ProvidedInStrategy.java [27:37]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    public String generateId(SinkRecord record) {
        String value = where == ProvidedIn.KEY
            ? Values.convertToString(record.keySchema(), record.key())
            : Values.convertToString(record.valueSchema(), record.value());
        try {
            Object object = JsonPath.parse(value).read(config.jsonPath());
            return sanitizeId(Values.convertToString(null, object));
        } catch (Exception e) {
            throw new ConnectException("Could not evaluate JsonPath " + config.jsonPath(), e);
        }
    }