Andreas Heider
Andreas Heider
Yes, that'd be really nice and make it easier to use. This build is done with https://github.com/ah-/librdkafka-build, want to give it a go? I'd love to merge a PR.
Hi Judy, what settings do you use for your consumer? Do you set a group id and auto commit offsets? Try auto.offset.reset=smallest, which should give you all the available messages....
Do you have a full minimal example? Do the example consumers work for you? Is enableAutoCommit set to true? Can you paste the log output?
Hi, it looks like this fails inside the underlying librdkafka. Could you maybe try asking at https://github.com/edenhill/librdkafka?
Could you maybe try using the python librdkafka.dll with the C# wrapper? Just replace the file. The one shipped with rdkafka has a statically compiled in OpenSSL, which is why...
The latest ci builds already use a final 0.9.2 librdkafka shared library. Could you try using some other 0.9.2 librdkafka.dll? I suspect the issue might be with how the bundled...
Hi, yeah that was the idea, all the binaries on nuget were built on the same CI server, so they might all have the same issues. A different build, especially...
Are you building for the same architecture? 64/32bit?
There's a local send queue which buffers the messages you produce before actually transmitting them to the broker. This queue is limited to a certain size (see queue.buffering.max.messages and queue.buffering.max.kbytes...
Could you reproduce this? Also there's now a 0.9.2 build up, could you try with that? Also there's a new parameter on Produce, if you call it with `topic.Produce(data, blockIfQueueFull:...