Uses of Class
io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration
-
-
Uses of KafkaConnectorIncomingConfiguration in io.smallrye.reactive.messaging.kafka.commit
Methods in io.smallrye.reactive.messaging.kafka.commit with parameters of type KafkaConnectorIncomingConfiguration Modifier and Type Method Description static KafkaThrottledLatestProcessedCommit
KafkaThrottledLatestProcessedCommit. create(io.vertx.mutiny.core.Vertx vertx, ReactiveKafkaConsumer<?,?> consumer, String groupId, KafkaConnectorIncomingConfiguration config, KafkaSource<?,?> source)
Constructors in io.smallrye.reactive.messaging.kafka.commit with parameters of type KafkaConnectorIncomingConfiguration Constructor Description KafkaLatestCommit(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorIncomingConfiguration configuration, ReactiveKafkaConsumer<?,?> consumer)
-
Uses of KafkaConnectorIncomingConfiguration in io.smallrye.reactive.messaging.kafka.fault
Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type KafkaConnectorIncomingConfiguration Modifier and Type Method Description static KafkaFailureHandler
KafkaDeadLetterQueue. create(Map<String,?> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)
-
Uses of KafkaConnectorIncomingConfiguration in io.smallrye.reactive.messaging.kafka.health
Constructors in io.smallrye.reactive.messaging.kafka.health with parameters of type KafkaConnectorIncomingConfiguration Constructor Description KafkaSourceHealth(KafkaSource<?,?> source, KafkaConnectorIncomingConfiguration config, ReactiveKafkaConsumer<?,?> client)
-
Uses of KafkaConnectorIncomingConfiguration in io.smallrye.reactive.messaging.kafka.impl
Constructors in io.smallrye.reactive.messaging.kafka.impl with parameters of type KafkaConnectorIncomingConfiguration Constructor Description KafkaRecordBatchStream(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.vertx.core.Context context)
KafkaRecordStream(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.vertx.core.Context context)
KafkaRecordStreamSubscription(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.smallrye.mutiny.subscription.MultiSubscriber<? super T> subscriber, io.vertx.core.Context context, int maxPollRecords, BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>,RecordQueue<T>> enqueueFunction)
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)
-