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