public class BrokerMetadata extends Object
public BrokerMetadata(int id, Optional<String> rack)
id
- an integer that uniquely identifies this brokerrack
- the rack of the broker, which is used to in rack aware partition assignment for fault tolerance.
Examples: "RACK1", "us-east-1d"public BrokerMetadata(int id, Optional<String> rack, Map<String,String> tags)
id
- an integer that uniquely identifies this brokerrack
- the rack of the broker, which is used to in rack aware partition assignment for fault tolerance.
Examples: "RACK1", "us-east-1d"tags
- the tags of the broker, specified by BrokerTags