Class RebalanceListeners
- java.lang.Object
-
- io.smallrye.reactive.messaging.kafka.impl.RebalanceListeners
-
public class RebalanceListeners extends Object
-
-
Constructor Summary
Constructors Constructor Description RebalanceListeners()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
inject(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener)
HACK - inject the listener using reflection to replace the one set by vert.x
-
-
-
Method Detail
-
inject
public static void inject(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener)
HACK - inject the listener using reflection to replace the one set by vert.x- Parameters:
consumer
- the consumerlistener
- the listener
-
-