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.

PropertyNotSetException

This exception is thrown when a mandatory property is not set while building configurations.

SerializationException

This exception is thrown when there is an error during message serialization.