Confluent-kafka-go: Allow users to search offsets by timestamp on partitions

Created on 14 Nov 2016  路  7Comments  路  Source: confluentinc/confluent-kafka-go

As of 0.10.0.1 the java library lets users seek to offsets based on timestamp.

https://kafka.apache.org/documentation#upgrade_1010_notable

enhancement

Most helpful comment

Sorry, not for this release. Will be available in the next one.

All 7 comments

offsets_for_times() support was just added to librdkafka, will be added to the Go client soon.

@edenhill Did this make it in? I may be missing something but I don't see it in the docs or in these tests:
https://github.com/confluentinc/confluent-kafka-go/blob/0.9.4.x/kafka/kafka_test.go

Whoop, closed the wrong issue.
No, offset_for_times is not yet added. Will be added for the next release.

@edenhill Will the release in June have this feature?

Sorry, not for this release. Will be available in the next one.

OffsetsForTimes is now available on master.

Was this page helpful?
0 / 5 - 0 ratings

Related issues

binary132 picture binary132  路  10Comments

wedneyyuri picture wedneyyuri  路  8Comments

kafkauser-symc picture kafkauser-symc  路  6Comments

yangxikun picture yangxikun  路  3Comments

pavelnikolov picture pavelnikolov  路  8Comments