Description
Background
While working on the PR for KIP-836, we realized that the `DescribeQuorum` API does not return the brokers as observers for the metadata log.
As noted by dengziming :
We set nodeId=-1 if it's a broker so observers.size==0
The related code is:
val nodeId = if (config.processRoles.contains(ControllerRole)) { OptionalInt.of(config.nodeId) } else { OptionalInt.empty() }
ToDo
We should fix this and have the DescribeMetadata API return the brokers as observers for the metadata log.
Attachments
Issue Links
- links to