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.