-
Notifications
You must be signed in to change notification settings - Fork 882
Closed
Labels
Description
Description
In a C# Windows service application, await producer.ProduceAsync() never return. but the message have sent and consumer received it. This issue both occurred in Confluent.Kafka nuget package of 0.11.6 & 1.0.0 beta3.
Add: Just tested other version and found:
- Confluent.Kafka 0.11.2 & librdkkafka.redist 0.11.1: Works
- Confluent.Kafka 0.11.3 & librdkkafka.redist 0.11.3: Works
- Confluent.Kafka 0.11.4 & librdkkafka.redist 0.11.4: Does not works
- Confluent.Kafka 0.11.5 & librdkkafka.redist 0.11.5: Does not works
- Confluent.Kafka 0.11.6 & librdkkafka.redist 0.11.6: Does not works
How to reproduce
var config = new ProducerConfig
{
BootstrapServers = "server:9092",
MessageTimeoutMs = 5000
};
var _producer = new ProducerBuilder<Null, string>(config).Build();
var message = new { Time = DateTime.Now };
LogHelper.Debug("Producer start...");
await _producer.ProduceAsync("myTopic", new Message<Null, string>{ Value = JsonConvert.SerializeObject(message)});
LogHelper.Debug("Producer end..."); //this line never executed
Checklist
Please provide the following information:
- Confluent.Kafka nuget version: 0.11.6 & 1.0.0-beta3
- Apache Kafka version: 2.11
- Client configuration: .NET Framework 4.6.2
- Operating system: Windows Server 2016
- Provide logs (with "debug" : "..." as necessary in configuration)
- Provide broker log excerpts
- Critical issue
ReidAnderson and jeffhollan