SmAnbu

Description =========== We are experiencing the below error intermittently Confluent.Kafka.ConsumeException: Local: Broker transport failure at Confluent.Kafka.Consumer`2.ConsumeImpl[K,V](Int32 millisecondsTimeout, IDeserializer`1 keyDeserializer, IDeserializer`1 valueDeserializer) at Confluent.Kafka.Consumer`2.Consume(CancellationToken cancellationToken) at just want to know whether...

Description =========== We are experiencing the below error intermittently while consuming the messages from Kafka Confluent.Kafka.ConsumeException: Local: Timed out at Confluent.Kafka.Consumer`2.ConsumeImpl[K,V](Int32 millisecondsTimeout, IDeserializer`1 keyDeserializer, IDeserializer`1 valueDeserializer) at Confluent.Kafka.Consumer`2.Consume(CancellationToken cancellationToken) How...