Skip to content

Query offsets_for_times using specified partitions

Afonso Mukai requested to merge fix-start-time-matthew-contribution into fix-start-time

Created by: matthew-d-jones

Note, based on fix-start-time branch.

This works for me. The debug log I added in these changes shows the correct offset being found for the partition.

The problem was that offsets_for_times must be called for specific partitions, not for topics with RD_KAFKA_PARTITION_UA set. The changes here do a metadata query to find out what partitions exist for the given topic and creates a TopicPartition for each of them.

Merge request reports