Uses of Class
io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration
-
Packages that use KafkaConnectorIncomingConfiguration Package Description io.smallrye.reactive.messaging.kafka.commit io.smallrye.reactive.messaging.kafka.fault io.smallrye.reactive.messaging.kafka.impl -
-
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 KafkaThrottledLatestProcessedCommitKafkaThrottledLatestProcessedCommit. create(io.vertx.mutiny.core.Vertx vertx, io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> 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, io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> 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 KafkaFailureHandlerKafkaDeadLetterQueue. create(io.vertx.mutiny.core.Vertx vertx, Map<String,String> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents) -
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 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)
-