Skip to content

Commit

Permalink
querywatermark addition from 1.6.2 release (KxSystems#100)
Browse files Browse the repository at this point in the history
  • Loading branch information
sshanks-kx authored Mar 13, 2023
1 parent 3da6115 commit 5af24b7
Showing 1 changed file with 20 additions and 1 deletion.
21 changes: 20 additions & 1 deletion docs/reference.md
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,8 @@ Clients<br>
Offsets<br>
[`CommitOffsets`](#commitoffsets) Commit offsets on broker for provided partition list<br>
[`PositionOffsets`](#positionoffsets) Current offsets for topics and partitions<br>
[`CommittedOffsets`](#committedoffsets) Retrieve committed offsets for topics and partitions
[`CommittedOffsets`](#committedoffsets) Retrieve committed offsets for topics and partitions<br>
[`queryWatermark`](#querywatermark) Query broker for low (oldest/beginning) and high (newest/end) offsets for partition.

Publishing <br>
[`BatchPub`](#batchpub) Publish a batch of data to a defined topic<br>
Expand Down Expand Up @@ -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`
Expand Down

0 comments on commit 5af24b7

Please sign in to comment.