private ConfigMapper()

in appender/kafka/src/main/java/org/apache/karaf/decanter/appender/kafka/ConfigMapper.java [31:58]

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

    private ConfigMapper(Dictionary<String, Object> conf) {
        this.confSource = conf;
        config = new Properties();
        process("bootstrap.servers", "localhost:9092");
        process("client.id", "");
        process("compression.type", "none");
        process("acks", "all");
        process("retries", "0");
        process("batch.size", "16384");
        process("buffer.memory", "33554432");
        process("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        process("request.timeout.ms", "5000");
        process("max.request.size", "2097152");
        process("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        process("security.protocol");
        process("ssl.truststore.location");
        process("ssl.truststore.password");
        process("ssl.keystore.location");
        process("ssl.keystore.password");
        process("ssl.key.password");
        process("ssl.provider");
        process("ssl.cipher.suites");
        process("ssl.enabled.protocols");
        process("ssl.truststore.type");
        process("ssl.keystore.type");
        
        process("topic", "decanter");
    }