Uses of Interface
io.smallrye.reactive.messaging.kafka.SerializationFailureHandler
-
Packages that use SerializationFailureHandler Package Description io.smallrye.reactive.messaging.kafka.fault io.smallrye.reactive.messaging.kafka.impl -
-
Uses of SerializationFailureHandler in io.smallrye.reactive.messaging.kafka.fault
Constructors in io.smallrye.reactive.messaging.kafka.fault with parameters of type SerializationFailureHandler Constructor Description SerializerWrapper(String className, boolean handleKeys, SerializationFailureHandler<T> failureHandler) -
Uses of SerializationFailureHandler in io.smallrye.reactive.messaging.kafka.impl
Constructors in io.smallrye.reactive.messaging.kafka.impl with parameters of type SerializationFailureHandler Constructor Description ReactiveKafkaProducer(Map<String,Object> kafkaConfiguration, String channel, int closeTimeout, SerializationFailureHandler<K> keySerializationFailureHandler, SerializationFailureHandler<V> valueSerializationFailureHandler)Constructor parameters in io.smallrye.reactive.messaging.kafka.impl with type arguments of type SerializationFailureHandler Constructor Description KafkaSink(KafkaConnectorOutgoingConfiguration config, KafkaCDIEvents kafkaCDIEvents, javax.enterprise.inject.Instance<SerializationFailureHandler<?>> serializationFailureHandlers)ReactiveKafkaProducer(KafkaConnectorOutgoingConfiguration config, javax.enterprise.inject.Instance<SerializationFailureHandler<?>> serializationFailureHandlers)
-