Modifier and Type | Method and Description |
---|---|
static KafkaThrottledLatestProcessedCommit |
KafkaThrottledLatestProcessedCommit.create(io.vertx.mutiny.core.Vertx vertx,
ReactiveKafkaConsumer<?,?> consumer,
String groupId,
KafkaConnectorIncomingConfiguration config,
KafkaSource<?,?> source) |
Constructor and Description |
---|
KafkaLatestCommit(io.vertx.mutiny.core.Vertx vertx,
KafkaConnectorIncomingConfiguration configuration,
ReactiveKafkaConsumer<?,?> consumer) |
Modifier and Type | Method and Description |
---|---|
static KafkaFailureHandler |
KafkaDeadLetterQueue.create(io.vertx.mutiny.core.Vertx vertx,
Map<String,?> kafkaConfiguration,
KafkaConnectorIncomingConfiguration conf,
KafkaSource<?,?> source,
KafkaCDIEvents kafkaCDIEvents) |
Constructor and Description |
---|
KafkaSourceReadinessHealth(KafkaSource<?,?> source,
io.vertx.mutiny.core.Vertx vertx,
KafkaConnectorIncomingConfiguration config,
Map<String,?> kafkaConfiguration,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
Set<String> topics,
Pattern pattern) |
Constructor and Description |
---|
KafkaRecordStream(ReactiveKafkaConsumer<K,V> client,
KafkaConnectorIncomingConfiguration config,
io.vertx.core.Context context) |
KafkaSource(io.vertx.mutiny.core.Vertx vertx,
String consumerGroup,
KafkaConnectorIncomingConfiguration config,
javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners,
KafkaCDIEvents kafkaCDIEvents,
javax.enterprise.inject.Instance<DeserializationFailureHandler<?>> deserializationFailureHandlers,
int index) |
ReactiveKafkaConsumer(KafkaConnectorIncomingConfiguration config,
KafkaSource<K,V> source) |
Copyright © 2018–2021 SmallRye. All rights reserved.