Exceptions
BufferFullException
This exception is thrown if produce is attempted while the message buffer has reached the
configured messageBufferSize
.
ConsumeFailedException
This exception is thrown if there is any 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 any 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.