Any plans to expose offsetsForTimes method on Consumer

[denisivan0v]

Java consumer API has the method

Map<TopicPartition,OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch)

which helps to assign a consumer to a specified offset based on timestamp.

Is there any plans to support this in .NET API?

[mhowlett]

Should be easy to add (corresponding function exists in librdkafka) but hasn't been prioritized - you're the first person to ask for the dotnet client I think.

PRs accepted :-)

[denisivan0v]

I'll take a look. Will be appreciated for docs/guidelines describing how to work with librdkafka correctly.

[denisivan0v]

Here is the corresponding Kafka improvement proposal: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65868090. And the librdkafka issue: confluentinc/librdkafka#842

Also, found the similar issue #85

[mhowlett]

The relevant librdkafka function is rd_kafka_offsets_for_times.
This should be wrapped in LibRdKafka.cs (for examples, see other methods).
Then exposed as a method on Consumer.

Ahh yes, I forgot someone else asked for this :-). It'd be a quick win, we should do this. Any help appreciated, but I'll try to get to it sooner rather than later.

[denisivan0v]

I've started to implement this method, but stuck at passing arguments to librdkafka.
Here is my commit denisivan0v@8ff96ae.

Now I need to convert IEnumerable<KeyValuePair<TopicPartition, long>> instance to rd_kafka_topic_partition_list_t instance to call the corresponding method https://github.com/edenhill/librdkafka/blob/master/src/rdkafka.c#L2433. But I'm really not sure how to do it.

@mhowlett, can you give me an advice on this? Comments on current changes are also appreciated.

[mhowlett]

Have a look in SafeKafkaHandle for something similar... perhaps GetCTopicPartitionList. This conversion should happen in SafeKafkaHandle - sorry didn't think of that before.

[denisivan0v]

Pinned: java implementation is here https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L1489

[melnikov77]

Any plans to release this method? I can't find it in "0.11.0.x" branch :-(

[mhowlett]

it will be in the next major release, or you can use a package from the appveyor nuget feed.

[jake0029]

Sorry, do we have sample usage of OffsetFortimes event in .net code? Thank you