Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka.commit | |
io.smallrye.reactive.messaging.kafka.fault |
Modifier and Type | Method and Description |
---|---|
static KafkaThrottledLatestProcessedCommit |
KafkaThrottledLatestProcessedCommit.create(io.vertx.mutiny.core.Vertx vertx,
io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> consumer,
String groupId,
KafkaConnectorIncomingConfiguration config,
KafkaSource<?,?> source) |
Modifier and Type | Method and Description |
---|---|
static KafkaFailureHandler |
KafkaDeadLetterQueue.create(io.vertx.mutiny.core.Vertx vertx,
Map<String,String> kafkaConfiguration,
KafkaConnectorIncomingConfiguration conf,
KafkaSource<?,?> source,
KafkaCDIEvents kafkaCDIEvents) |
Constructor and Description |
---|
DeserializerWrapper(String className,
boolean key,
DeserializationFailureHandler<T> failureHandler,
KafkaSource<?,?> source) |
KafkaDeadLetterQueue(String channel,
String topic,
io.vertx.mutiny.kafka.client.producer.KafkaProducer producer,
KafkaSource<?,?> source) |
KafkaFailStop(String channel,
KafkaSource<?,?> source) |
Copyright © 2018–2021 SmallRye. All rights reserved.