IConsumer.OffsetsForTimes method
public List<TopicPartitionOffset> OffsetsForTimes(
IEnumerable<TopicPartitionTimestamp> topicPartitions, TimeSpan timeout)
See Also
- interface IConsumer
- namespace KafkaFlow.Consumers
public List<TopicPartitionOffset> OffsetsForTimes(
IEnumerable<TopicPartitionTimestamp> topicPartitions, TimeSpan timeout)