private void ConfigureConsumerConfig()

in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs [443:463]

• 17 lines of code
• 5 McCabe index (conditional complexity)

    private void ConfigureConsumerConfig(ConsumerConfig config)
    {
        if (config == null)
        {
            throw new ArgumentNullException(nameof(config));
        }

        config.EnableAutoCommit = false;
        config.EnableAutoOffsetStore = false;

        if (config.All(x => x.Key != KafkaConfigExtensions.DotnetLoggerCategoryKey))
        {
            config.SetDotnetLoggerCategory(this.Monitor.FullName);
        }

        if (this.Options.StateType.Name == typeof(CombinedState<>).Name || this.Options.StateType == typeof(InternalKafkaState))
        {
            // to avoid leaving group in case of long-running processing
            config.MaxPollIntervalMs ??= (int)TimeSpan.FromMinutes(60).TotalMilliseconds;
        }
    }