Silviu Caragea

More specific: https://github.com/silviucpp/erlkaf/blob/master/src/erlkaf.erl#L131

Hello, I see what do you mean. For sure is not used to order the messages because for this you have the offset. I see there is a property form...

Hello, to be clear: we don't support kafka streams. librdkafka is not planning to support this as well. For the timestamp: I will add it when I will have some...

I think you misunderstand this or maybe I'm doing it. The only api in librdkafka is to get the timestamp that's assigned by the broker. There is no api to...

Hello @lud , I had some time yesterday - today to look into this and librdkafka source code and yes it can be done you are right. Seems if not...

I honestly believe this approach is wrong. Better is to use the librdkafka api for pausing/resuming consumers. Just to give you an example with the implementation you did in case...

I'm talking about the api's https://github.com/edenhill/librdkafka/blob/58aa3ab832172770b1b690a06900df9c297b135c/src/rdkafka.h#L3029

Hello, There is no roadmap for any new feature. Any PR is welcome. I usually implemented the features I'm using in our applications. Silviu

Have you tried to set the transactional_id into the producer ? I didn't studied exactly if this is the only thing needed or might need some other changes as well....

I answered this question myself after a bit of research: it seems that Datastax continues to do what it has been doing for a long time (trying to shut down...