What happens at the back end is a call to ApplicationLeaders() on the *State struct.
It seems kafka is not in the known list of leadership lease holders.
Can you confirm if you are running with legacy leases or raft leases?
If raft leases, can you look at the leaseholders collection to see if there's a "application-leadership" lease for kafka in there?
What happens at the back end is a call to ApplicationLead ers() on the *State struct.
It seems kafka is not in the known list of leadership lease holders.
Can you confirm if you are running with legacy leases or raft leases?
If raft leases, can you look at the leaseholders collection to see if there's a "application- leadership" lease for kafka in there?