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.health
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 and 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 and 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 and 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 and 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 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)