IMessageConsumer.QueryWatermarkOffsets method
Query the Kafka cluster for low (oldest available/beginning) and high (newest/end) offsets for the specified topic/partition. This is a blocking call - always contacts the cluster for the required information.
public WatermarkOffsets QueryWatermarkOffsets(TopicPartition topicPartition, TimeSpan timeout)
| parameter | description |
|---|---|
| topicPartition | The topic/partition of interest. |
| timeout | The maximum period of time the call may block. |
Return Value
The requested WatermarkOffsets (see that class for additional documentation).
See Also
- interface IMessageConsumer
- namespace KafkaFlow.Consumers