Query offsets_for_times using specified partitions
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.