return 9092 + ThreadLocalRandom.current().nextLong(0, 1000);
}
private OfferRequirement getNewOfferRequirementInternal(String configName, int brokerId)
throws InvalidRequirementException, IOException, URISyntaxException {
log.info("Getting new OfferRequirement for: " + configName);
<BUG>String brokerName = OfferUtils.idToName(brokerId);
</BUG>
String containerPath = "kafka-volume-" + UUID.randomUUID();
KafkaSchedulerConfiguration config = configState.fetch(UUID.fromString(configName));
log.warn("KafkaSchedulerConfiguration: " + config);

return 9092 + ThreadLocalRandom.current().nextLong(0, 1000);
}
private OfferRequirement getNewOfferRequirementInternal(String configName, int brokerId)
throws InvalidRequirementException, IOException, URISyntaxException {
log.info("Getting new OfferRequirement for: " + configName);
String brokerName = OfferUtils.brokerIdToTaskName(brokerId);
String containerPath = "kafka-volume-" + UUID.randomUUID();
KafkaSchedulerConfiguration config = configState.fetch(UUID.fromString(configName));
log.warn("KafkaSchedulerConfiguration: " + config);
