KafkaIngesterException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.deephaven.UncheckedDeephavenException

io.deephaven.kafka.ingest.KafkaIngesterException

All Implemented Interfaces:: Serializable

public class KafkaIngesterException
extends UncheckedDeephavenException

This exception is thrown when there is a failure to consume a Kafka record during Kafka to Deephaven ingestion.

See Also:: Serialized Form

Constructor Summary

Constructors
Constructor	Description
`KafkaIngesterException(String reason)`	Constructs a new KafkaIngesterException with the specified reason.
`KafkaIngesterException(String reason, Exception cause)`	Constructs a new KafkaIngesterException with the specified reason.

Method Summary

Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- KafkaIngesterException
  
  public KafkaIngesterException(String reason, Exception cause)
  
  Constructs a new KafkaIngesterException with the specified reason.
  
  Parameters:
  
  reason - the exception detail message
  
  cause - the exception cause
- KafkaIngesterException
  
  public KafkaIngesterException(String reason)
  
  Constructs a new KafkaIngesterException with the specified reason.
  
  Parameters:
  
  reason - the exception detail message