package exception
Type Members
- class KafkaExceptionConsumerProvider extends FlinkEspExceptionConsumerProvider
- case class SharedProducerKafkaExceptionConsumer(metaData: MetaData, serializationSchema: KafkaSerializationSchema[NuExceptionInfo[NonTransientException]], kafkaProducerCreator: Binary, kafkaErrorTopicInitializer: KafkaErrorTopicInitializer) extends FlinkEspExceptionConsumer with WithSharedKafkaProducer with Product with Serializable
- case class TempProducerKafkaExceptionConsumer(serializationSchema: KafkaSerializationSchema[NuExceptionInfo[NonTransientException]], kafkaProducerCreator: Binary, kafkaErrorTopicInitializer: KafkaErrorTopicInitializer) extends FlinkEspExceptionConsumer with Product with Serializable