quarkus-test-suite
quarkus-test-suite copied to clipboard
Add a way to check creation and rebalancing of Kafka topics
In the KafkaGratefulShutdownIT[1] we create topics and then sleep for a second until they are ready to accept messages. Recommended solution from Quarkus team[2] is to "access the underlying Kafka client and write a check on that" or "to write a custom consumer rebalance listener to listen rebalance events". We should implement one of these
[1] https://github.com/quarkus-qe/quarkus-test-suite/blob/f4aefae1b348c67c25a43d1406c88ee1dfdcfc3c/messaging/kafka-streams-reactive-messaging/src/test/java/io/quarkus/ts/messaging/kafka/reactive/streams/KafkaGratefulShutdownIT.java#L48
[2] https://github.com/quarkusio/quarkus/issues/41441#issuecomment-2203068816