Confluent-kafka-dotnet: Message headers support

[jeroenheijmans]

Someone asked on Stack Overflow about message headers support. I see that @mhowlett already answered that this depends on the related PR in librdkafka.

I hope you don't mind, but I'd like to open this issue here (search gave 0 results atm), because I'd love to track the status for this SDK _specifically_.

I understand that at the time of opening this issue, it will immediately be marked as blocked. But once it gets unblocked I'd love to get GitHub notifications on progress here.

Either way, thanks a bunch for the SDK and all the hard work y'all put in! 👍

[mhowlett]

thanks @jeroenheijmans, +1 noted.

[dianagastrin]

@mhowlett, I saw that the related PR in librdkafka
was merged. I would like to know when you are going to support message headers.

Is this something I can easily implement by myself?
I just really need to use 'headers' as part of my flow, I wonder if this would be easy to implement by myself for now and change the logic when it would be supported in 'confluent-kafka-dotnet'...

[mhowlett]

this is part of (the large) PR #431 that we're trying to finalize this week.

a CI build that includes this functionality is on nuget.org (0.11.3-ci-280) which I believe is stable, though you can expect API changes

[dianagastrin]

Hi @mhowlett,
Once I get this version - 0.11.3-ci-280, how can I use the headers? Is there an API for that?
Thanks!!

[mhowlett]

yes, there are overloads of ProduceAsync and Produce that accept a headers collection. Note that the API will be different in the final version, but it will be similar and easy to change.

[jeroenheijmans]

Should someone land on this thread via a search or some such, be aware that the discussion on which version this feature might land in continued in #472.

(The short answer being that the headers might not land until a major version release.)