Specify the port with annotation

[JBertaux]

Hello,
With the class rule EmbeddedKafkaRule this is possible to specify the port like that:

public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1, true, "topic").kafkaPorts(9092);

How can I achieve the same with the annotation ? (I use Junit 5)

@EmbeddedKafka(controlledShutdown = true, topics = {"topic"})

[garyrussell]

It's not currently supported via the annotation; you can, however, define an EmbeddedKafkaBroker @Bean in the test application context (that's all that the annotation does), and customize it there.

@Bean
public EmbeddedKafkaBroker broker() {
    return new EmbeddedKafkaBroker(...).kafkaPorts(...);

[artembilan]

I think this is not too bad to support on the annotation level:

/**
 * @return ports for brokers.
 */
int[] ports() default { };

So, treating this as an improvement.
And that's not too late yet to implement in the current version.