You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
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]
quarkus-test-suite/messaging/kafka-streams-reactive-messaging/src/test/java/io/quarkus/ts/messaging/kafka/reactive/streams/KafkaGratefulShutdownIT.java
Line 48 in f4aefae
[2] quarkusio/quarkus#41441 (comment)
The text was updated successfully, but these errors were encountered: