Class BufferExhaustedException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.common.errors.ApiException
org.apache.kafka.common.errors.RetriableException
org.apache.kafka.common.errors.TimeoutException
org.apache.kafka.clients.producer.BufferExhaustedException
All Implemented Interfaces:
Serializable
public class BufferExhaustedExceptionextends TimeoutException
This exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full. In earlier versions a TimeoutException was thrown instead of this. To keep existing catch-clauses working this class extends TimeoutException.
See Also:

  • Constructor Details

    • BufferExhaustedException

      public BufferExhaustedException(String message)
      Constructs a new BufferExhaustedException with the specified detail message.
      Parameters:
      message - The error message