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.

ProduceFailedException

This exception is thrown if there is any error in the underlying Kafka producer when producing.

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.