Is compression in fact supported?

[winbatch]

The introduction seems to indicate yes, but the rdkafka_int.h indicates no/not supported in the enum definition of rd_kafka_compression_t. Hoping that it's simply outdated?

[edenhill]

Those comments are indeed outdated, compression is supported.
I will remove the comments.

Thanks

[winbatch]

Cool. Can you confirm that when a consumer receives a message, he has no way of knowing whether it is compressed and by what algorithm, correct? (So a mutual understanding is required between producer and consumer?)

[edenhill]

The compression codec used is set in the message header and the consumer will decompress the message accordingly. This also allows for some producers to employ compression and some dont, while producing to the same topic and partition.

So there is no need for any producer <-> consumer correlation.

[winbatch]

Excellent. Will give it a shot. Thanks again.