public static EphemeralKafkaBroker create ( int kafkaPort , int zookeeperPort , Properties overrideBrokerProperties ) { return new EphemeralKafkaBroker ( kafkaPort , zookeeperPort , overrideBrokerProperties ) ; }
Create a new ephemeral Kafka broker with the specified broker port Zookeeper port and config overrides .