Class RecordTooLargeException

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.RecordTooLargeException
All Implemented Interfaces:
Serializable
public class RecordTooLargeExceptionextends ApiException
This record is larger than the maximum allowable size
See Also:

  • Constructor Details

    • RecordTooLargeException

      public RecordTooLargeException()

    • RecordTooLargeException

      public RecordTooLargeException(String message, Throwable cause)

    • RecordTooLargeException

      public RecordTooLargeException(String message)

    • RecordTooLargeException

      public RecordTooLargeException(Throwable cause)

    • RecordTooLargeException

      public RecordTooLargeException(String message, Map<TopicPartition, Long> recordTooLargePartitions)

  • Method Details