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