quarkus-test-suite icon indicating copy to clipboard operation
quarkus-test-suite copied to clipboard

Add a way to check creation and rebalancing of Kafka topics

Open fedinskiy opened this issue 5 months ago • 0 comments

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

fedinskiy avatar Sep 18 '24 13:09 fedinskiy