1// A common struct used in DescribeQuorumResponse.
2DescribeQuorumResponseTopicPartitionReplicaState => not top level, no encoding, flexible v0+
3 ReplicaID: int32
4 // The last known log end offset of the follower, or -1 if it is unknown.
5 LogEndOffset: int64
6 // The last known leader wall clock time when a follower fetched from the
7 // leader, or -1 for the current leader or if unknown for a voter.
8 LastFetchTimestamp: int64(-1) // v1+
9 // The leader wall clock append time of the offset for which the follower
10 // made the most recent fetch request, or -1 for the current leader or if
11 // unknown for a voter.
12 LastCaughtUpTimestamp: int64(-1) // v1+
13
14// Part of KIP-642 (and KIP-595) to replace Kafka's dependence on Zookeeper with a
15// Kafka-only raft protocol,
16// DescribeQuorumRequest is sent by a leader to describe the quorum.
17DescribeQuorumRequest => key 55, max version 1, flexible v0+, admin
18 Topics: [=>]
19 Topic: string
20 Partitions: [=>]
21 Partition: int32
22
23DescribeQuorumResponse =>
24 ErrorCode: int16
25 Topics: [=>]
26 Topic: string
27 Partitions: [=>]
28 Partition: int32
29 ErrorCode: int16
30 // The ID of the current leader, or -1 if the leader is unknown.
31 LeaderID: int32
32 // The latest known leader epoch.
33 LeaderEpoch: int32
34 HighWatermark: int64
35 CurrentVoters: [DescribeQuorumResponseTopicPartitionReplicaState]
36 Observers: [DescribeQuorumResponseTopicPartitionReplicaState]
View as plain text