private void mapProducer()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/ConfigMapper.java [64:74]

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

    private void mapProducer() {
        process("acks", "all");
        process("compression.type", "none");
        process("max.request.size", "2097152");
        process("retries", "0");
        process("batch.size", "16384");
        process("buffer.memory", "33554432");
        config.put("key.serializer", StringSerializer.class);
        config.put("value.serializer", StringSerializer.class);
        process("request.timeout.ms", "15000");
    }