Andreas Heider
Andreas Heider
It's currently sync underneath. I think at the time there was only the sync API and I intended to switch it out for the async later and therefore gave it...
Yes 500 milliseconds sounds like it is in the right ballpark. Maybe you can get this down with a bit of tuning of broker/client settings, but I'm not sure it's...
Hi Andrew, thanks for your bug report and pull request! Produce will keep trying until `message.timeout.ms` passes. It's 5 minutes by default, I don't don't remember if that includes retries....
Hi, thanks for checking. I'm busy today but will have a closer look tomorrow.
Hi, from 0.9.2-ci-177 onwards you can now use `topic.Produce(data, blockIfQueueFull: false);` to tell RdKafka that you would like to handle a full local queue yourself. It will throw an RdKafkaException...
Hi, is the message delivered successfully? Producer.Dispose will block until all messages in flight have either been delivered or timed out. Try enabling config["debug"] = "all" to see what's going...
Is this maybe one of the callbacks throwing an exception?
Hey, This was added in librdkafka 0.9.2. Try the latest pre-release package.
> What do you think about the following two hunches? > > When SafeKafkaHandle.ReleaseHandle is called via the SafeHandle finalizer, these can be called in random order. Hence a producer...
That must be it! Handle should implement the full Dispose() pattern (https://msdn.microsoft.com/en-us/library/b1yfkh5e(v=vs.110).aspx) then I think this should stop happening. Although, reading the docs it seems like it shouldn't crash if...