Applied timeout for Producer.SendMessageAsync for case when connection is unavailable

Jroland / kafka-net

Native C# client for Kafka queue servers.

Apache License 2.0

483 stars 232 forks source link

Open avtc opened 7 years ago

avtc commented 7 years ago

In that case ProduceResponse result will have Error = Producer.ErrorOnTimeout (-1) Previously it caused infinite waiting