public Properties getDlqProps()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [452:460]

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

    public Properties getDlqProps() {
        Map<String, Object> dlqconfigs = originalsWithPrefix(DLQ_PROPS_PREFIX);
        Properties props = new Properties();
        props.putAll(dlqconfigs);
        props.put("bootstrap.servers", getDlqBootstrapServers());
        props.put("key.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
        return props;
    }