public class RebalanceListeners extends Object
Constructor and Description |
---|
RebalanceListeners() |
Modifier and Type | Method and 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
|
public static void inject(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener)
consumer
- the consumerlistener
- the listenerCopyright © 2018–2021 SmallRye. All rights reserved.