From 5af24b75720077c71c9a6a70766c9d2965e60907 Mon Sep 17 00:00:00 2001
From: Simon Shanks <59612559+sshanks-kx@users.noreply.github.com>
Date: Mon, 13 Mar 2023 14:08:22 +0000
Subject: [PATCH] querywatermark addition from 1.6.2 release (#100)
---
docs/reference.md | 21 ++++++++++++++++++++-
1 file changed, 20 insertions(+), 1 deletion(-)
diff --git a/docs/reference.md b/docs/reference.md
index fda6dc5..d09a6a4 100644
--- a/docs/reference.md
+++ b/docs/reference.md
@@ -33,7 +33,8 @@ Clients
Offsets
[`CommitOffsets`](#commitoffsets) Commit offsets on broker for provided partition list
[`PositionOffsets`](#positionoffsets) Current offsets for topics and partitions
-[`CommittedOffsets`](#committedoffsets) Retrieve committed offsets for topics and partitions
+[`CommittedOffsets`](#committedoffsets) Retrieve committed offsets for topics and partitions
+[`queryWatermark`](#querywatermark) Query broker for low (oldest/beginning) and high (newest/end) offsets for partition.
Publishing
[`BatchPub`](#batchpub) Publish a batch of data to a defined topic
@@ -538,6 +539,24 @@ test 0 26481 ""
test 1 -1001 ""
```
+
+### `queryWatermark`
+
+_Query broker for low (oldest/beginning) and high (newest/end) offsets for partition_
+
+```txt
+.kfk.queryWatermark[client;`test1;0;1000]
+```
+
+Where
+
+- `clid` is a consumer ID (integer)
+- `topic` is a topic (symbol)
+- `partition` partition (long)
+- `timeout` timeout in ms (long)
+
+returns 2 element long for low/high watermark
+
## Publishing functionality
### `BatchPub`