package exception
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class KafkaErrorTopicInitializer extends LazyLogging
- case class KafkaExceptionConsumerConfig(topic: String, stackTraceLengthLimit: Int = 50, includeHost: Boolean = true, includeInputEvent: Boolean = false, useSharedProducer: Boolean = false, additionalParams: Map[String, String] = Map.empty) extends Product with Serializable
- case class KafkaExceptionInfo(processName: String, nodeId: Option[String], message: Option[String], exceptionInput: Option[String], inputEvent: Option[String], stackTrace: Option[String], timestamp: Long, host: Option[String], additionalData: Map[String, String]) extends Product with Serializable
- class KafkaJsonExceptionSerializationSchema extends KafkaSerializationSchema[NuExceptionInfo[NonTransientException]]
Value Members
- object KafkaExceptionInfo extends Serializable