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.

SerializationException

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

TransactionSwitchedException

This exception is thrown when the underlying Kafka producer was switched to another cluster while a transaction was in progress. Developers should catch this exception, and when it occurs restart the transaction from the beginning.