...
With ZK marked deprecated in AK 3.5, only the fix in KRaft is in scope.
Additional High Watermark
...
advancement requirement
A bit quick recap of some key concepts.
...
--admin.config <String: config file> Configuration properties files to pass
to the admin client
--all-topic-partitions Perform election on all of the
eligible topic partitions based on
the type of election (see the --
election-type flag). Not allowed if
--topic or --path-to-json-file is
specified.
--bootstrap-server <String: host:port> A hostname and port for the broker to
connect to, in the form host:port.
Multiple comma separated URLs can be
given. REQUIRED.
// Updated field starts.
--election-type <[PREFERRED, UNCLEAN, LONGEST_LOG_PROACTIVE, LONGEST_LOG_BALANCED, DESIGNATION]:
Type of election to attempt. Possible
election type> values are "preferred" for preferred
leader election, or "unclean" for
a random unclean leader election,
or "longest_log_proactive"/"longest_log_balanced"
to choose the replica
with the longest log or "designation" for
electing the given replica to be the leader. If
preferred election is selection, the
election is only performed if the
current leader is not the preferred
leader for the topic partition. If
longest_log_proactive/longest_log_balanced/designation
election is selected, the
election is only performed if there
are no leader for the topic
partition. REQUIRED.
// Updated field ends.
--help Print usage information.
--partition <Integer: partition id> Partition id for which to perform an
election. REQUIRED if --topic is
specified.
// Updated field starts.
--path-to-json-file <String: Path to The JSON file with the list of
JSON file> partition for which leader elections
should be performed. This is an
example format. The desiredLeader field
is only required in DESIGNATION election.
{"partitions":
[{"topic": "foo", "partition": 1, "desiredLeader": 0},
{"topic": "foobar", "partition": 2, "desiredLeader": 1}]
}
Not allowed if --all-topic-partitions
or --topic flags are specified.
// Updated field ends.
--topic <String: topic name> Name of topic for which to perform an
election. Not allowed if --path-to-
json-file or --all-topic-partitions
is specified.
--version Display Kafka version.
|
Metrics
The following gauge metrics will be added for ELR
...
The following gauge metrics will be added for Unclean Recovery
...