DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Start mirroring a topic or set of topics (the topic --topics flag accepts regex expression):
...
Describe configured mirrors to check their lag compared to their source topics (use --mirror flag to filter other partitionsonly show partitions from a specific mirror):
| Code Block | ||
|---|---|---|
| ||
$ bin/kafka-mirrors.sh --bootstrap-server :9094 --describe MIRROR TOPIC PARTITION SOURCE-OFFSET DESTINATION-OFFSET LAG STATE my-mirror bar 0 - - - STOPPED my-mirror foo 0 69 66 3 MIRRORING my-mirror foo 1 94 84 10 MIRRORING my-mirror foo 2 94 90 4 MIRRORING new-mirror baz 0 - - - PAUSED new-mirror baz 1 - - - PAUSED |
...