| Package | Description |
|---|---|
| io.smallrye.reactive.messaging.kafka.fault | |
| io.smallrye.reactive.messaging.kafka.impl |
| Constructor and Description |
|---|
DeserializerWrapper(String className,
boolean key,
DeserializationFailureHandler<?> failureHandler,
KafkaSource<?,?> source) |
| Constructor and 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) |
Copyright © 2018–2021 SmallRye. All rights reserved.