Howdy,
I'm looking at adding an option to KafkaClusterTestKit to allow a test to
specify the broker port instead of always using a dynamically assigned port.
The API I'm considering is:
new KafkaClusterTestKit.Builder(nodes)
.setBrokerPort(nodeId, 19092)
.build();
If no port is specified, the current behavior would remain unchanged.
The main use case is allowing external processes to connect to an embedded
Kafka cluster without having to discover the dynamically assigned port.
Does this API make sense, or is there a better approach you'd recommend?
Also, would a change like this require a KIP?
Best,
Rick
