Exceptions
BufferFullException
This exception is thrown if produce is attempted while the message buffer has reached the
configured messageBufferSize
.
ConfigurationException
This exception is thrown if there is a configuration error.
Such exceptions can be raised during SslConfig
validation or during the instantiation of internal
objects when expected configuration properties are not provided.
ConsumeFailedException
This exception is thrown if there is an error in the underlying Kafka Consumer when consuming.
It is also returned in a wrapped Future
object of consumer.startConsuming()
method.
NoExistingSchemaException
This exception is thrown when an AVRO producer tries to produce using a schema that is not found in the system.
NoExistingStreamException
This exception is thrown when a consumer tries to consume from a stream that is not found in the system.
ProduceFailedException
This exception is thrown if there is an error in the underlying Kafka producer when producing.
ProducerWorkerCancelledException
This exception is thrown by the ProducerWorker
in case a produce is queued after it has been
cancelled or stopped.
PropertyNotSetException
This exception is thrown when a mandatory property is not set while building configurations.