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.