Description

We are experiencing the below error intermittently while consuming the messages from Kafka

Confluent.Kafka.ConsumeException: Local: Timed out at Confluent.Kafka.Consumer2.ConsumeImpl[K,V](Int32 millisecondsTimeout, IDeserializer1 keyDeserializer, IDeserializer1 valueDeserializer) at Confluent.Kafka.Consumer2.Consume(CancellationToken cancellationToken)

How to reproduce

The below configuration is using in our application return new ConsumerConfig { BootstrapServers = _consumerConfiguration.BootstrapServers, GroupId = _consumerConfiguration.GroupId, SessionTimeoutMs = 100000, AutoOffsetReset = AutoOffsetReset.Earliest, EnablePartitionEof = true, EnableAutoCommit = _consumerConfiguration.EnableAutoCommit };

Checklist

Please provide the following information:

• A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
• Confluent.Kafka nuget version.
• Apache Kafka version.
• Client configuration.
• Operating system.
• Provide logs (with “debug” : “…” as necessary in configuration).
• Provide broker log excerpts.
• Critical issue.