Packages

package exception

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class DefaultKafkaErrorTopicInitializer extends KafkaErrorTopicInitializer with LazyLogging
  2. trait KafkaErrorTopicInitializer extends AnyRef
  3. case class KafkaExceptionConsumerConfig(topic: String, stackTraceLengthLimit: Int = 50, maxMessageBytes: Int = 1048476, includeHost: Boolean = true, includeInputEvent: Boolean = false, useSharedProducer: Boolean = false, additionalParams: Map[String, String] = Map.empty) extends Product with Serializable
  4. case class KafkaExceptionInfo(processName: ProcessName, nodeId: Option[String], message: Option[String], exceptionInput: Option[String], inputEvent: Option[Json], stackTrace: Option[String], timestamp: Long, host: Option[String], additionalData: Map[String, String]) extends Product with Serializable
  5. class KafkaJsonExceptionSerializationSchema extends KafkaSerializationSchema[NuExceptionInfo[NonTransientException]]

Value Members

  1. object KafkaExceptionInfo extends Serializable
  2. object KafkaJsonExceptionSerializationSchema extends Serializable
  3. object NoopKafkaErrorTopicInitializer extends KafkaErrorTopicInitializer

Ungrouped