BatchBufferOverflowException

faststream.kafka.exceptions.BatchBufferOverflowException #

BatchBufferOverflowException(message_position)

Exception raised when a buffer overflow occurs when adding a new message to the batches.

Source code in faststream/kafka/exceptions.py

def __init__(self, message_position: int) -> None:
    self.message_position = message_position

message_position = message_position