private String getContinuationToken()

in src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java [122:128]

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

    private String getContinuationToken() {
        JsonNode leaseRecord = getLeaseContainerRecord();
        if (client == null || leaseRecord == null) {
            return null;
        }
        return leaseRecord.get(CONTINUATION_TOKEN).textValue();
    }