yinbiaoh comments

Repositories
Issues
Comments

Results 1 comments of


                                            yinbiaoh

Confluent.Kafka.ConsumeException: Local: Broker transport failure

I have same issue. Local: Broker transport failure 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) Same code works without issue on other...