Compression / Buffer issue about swiftkafka HOT 2 CLOSED

After @ianpartridge's comment on Slack regarding C library interfacing, I did some poking around myself and found that changing this line from RD_KAFKA_MSG_F_COPY to RD_KAFKA_MSG_F_BLOCK, the issue goes away.

I have no idea what those flags do and mean, other than the explanation from the librdkafka header here. I am therefore not sure if this is a change that'd be open to be PRed. Would love to have some feedback. Thanks!

from swiftkafka.

I made my own fork with this change and a note regarding installation at https://github.com/TelemetryDeck/SwiftKafka

Sadly, the change has not helped. In fact, every 10th message or so is now completely garbled. I think at this point I'll abandon SwiftKafka (and Kafka as a message queue) in favor of something more maintained.

(I'm not expecting anyone to read this, but if you stumble in here in the year 2048, looking for a solution, say hi! Sorry for not solving climate change.)

from swiftkafka.