Matt Usifer
Results
2
issues of
Matt Usifer
This PR adds a new consumer function - `get_watermark_offsets` - which leverages the [get_watermark_offsets](https://docs.confluent.io/platform/current/clients/librdkafka/html/classRdKafka_1_1Handle.html#ab37fddad61506c8749214f1f009d17ca) librdkafka binding to return the _last known_ watermark values for a topic/partition. This is essentially a...
# PR Summary # PR checklist Please make sure that the following things have been addressed (and check the relevant checkboxes): - [ ] Commits respect our [guidelines](../CONTRIBUTING.rst) - [...