confluent-kafka-dotnet: await producer.ProduceAsync() never return
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
About this issue
- Original URL
- State: closed
- Created 5 years ago
- Reactions: 2
- Comments: 37 (13 by maintainers)
thanks for confirming @cmills2000 - the power of open source at work! I plan to get this resolved before the next release.
I had the same error “await producer async never return”. The cause was SSL wrong configuration. My recomendation: set the Debug config property to “all” and see the log