Table of Contents |
---|
Status
Current state: Under Discussion Accepted
Discussion thread: here
JIRA: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
When running kafka-metadata-quorum script to get the quorum replication status, the LastFetchTimestamp and LastCaughtUpTimestamp output is not human-readable.
I will It would be convenient to add an optional flag (-hr, --human-readable) to enable a human-readable format showing the operation delay in ms (i.e. 366 ms ago).
This delay is computed as (now - timestamp), where they are both represented as Unix time (UTC based).
Public Interfaces
A new optional flag called --human-readable with the shortcut -hr will be added to the kafka-metadata-quorum tool.
Code Block | ||
---|---|---|
| ||
$ bin/kafka-metadata-quorum.sh describe -h usage: kafka-metadata-quorum [-h] --bootstrap-server BOOTSTRAP_SERVER describe [-h] [-command-config COMMAND_CONFIGstatus] [--replication] [-hr] {describe} ... This tool describes kraft metadata quorum status. positional arguments: {describe} describe Describe the metadata quorum info-human-readable] optional arguments: -h, --help show this help message and exit Status: --bootstrap-server BOOTSTRAP_SERVER status A short summary of the quorum status and the other provides Adetailed comma-separated list of host:port pairs to use for establishinginformation about the connectionstatus to the Kafka cluster.of replication. Replication: --command-config COMMAND_CONFIG replication Detailed information about the status Property file containing configs to be passed to Admin Client.of replication -hr, --human-readable Print humanHuman-readable timestamps (default: false)output |
Proposed Changes
The current default --replication output is as follows and will remain unchanged.
...
Instead, when passing the new flag, we will have the following output (note how argparse4j support abbreviations).
Code Block | ||
---|---|---|
| ||
$ bin/kafka-metadata-quorum.sh --bootstrap-server :9092 -hr describe --replication --human-readable NodeId LogEndOffset Lag LastFetchTimestamp LastCaughtUpTimestamp Status 2 541 8689 0 34 ms ago 34 ms ago Leader 3 5418689 0 366148 ms ago 366148 ms ago Follower 4 541 8689 0 366148 ms ago 366148 ms ago Follower $ bin/kafka-metadata-quorum.sh --bootstrap-serverboot :9092 describe --human-readablere describe --replicationhu NodeId LogEndOffset Lag LastFetchTimestamp LastCaughtUpTimestamp Status 2 54161 0 35 ms ago 35 ms ago Leader 3 54161 0 36656 ms ago 36656 ms ago Follower 4 54161 0 36656 ms ago 36656 ms ago Follower |
Compatibility, Deprecation, and Migration Plan
...
Using a date/time formatting (i.e. May 10, 15:54:55 UTC) won't add much information in most cases and you will have to deal with locale.