public static GlobalPartitionInformation buildPartitionInfo(int numPartitions, int brokerPort) { GlobalPartitionInformation globalPartitionInformation = new GlobalPartitionInformation(TOPIC); for (int i = 0; i < numPartitions; i++) { globalPartitionInformation.addPartition(i, Broker.fromString("broker-" + i + " :" + brokerPort)); } return globalPartitionInformation; }