public static KafkaResumeStrategyConfigurationBuilder getDefaultKafkaResumeStrategyConfigurationBuilder()

in resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/KafkaUtil.java [41:54]

13 lines of code
1 McCabe index (conditional complexity)


    public static KafkaResumeStrategyConfigurationBuilder getDefaultKafkaResumeStrategyConfigurationBuilder() {
        String bootStrapAddress = System.getProperty("bootstrap.address", "localhost:9092");
        String kafkaTopic = System.getProperty("resume.type.kafka.topic", "offsets");

        return KafkaResumeStrategyConfigurationBuilder.newBuilder()
                .withBootstrapServers(bootStrapAddress)
                .withTopic(kafkaTopic)
                .withProducerProperty("max.block.ms", "10000")
                .withMaxInitializationDuration(Duration.ofSeconds(5))
                .withProducerProperty("delivery.timeout.ms", "30000")
                .withProducerProperty("session.timeout.ms", "15000")
                .withProducerProperty("request.timeout.ms", "15000")
                .withConsumerProperty("session.timeout.ms", "20000");
    }