Coverage for faststream / kafka / exceptions.py: 80%

1from faststream.exceptions import FastStreamException (empty)

2 

3 

4class BatchBufferOverflowException(FastStreamException): (empty)

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

6 

7 def __init__(self, message_position: int) -> None: (empty)

8 self.message_position = message_position (empty)

9 

10 def __str__(self) -> str: (empty)

11 return ( 

12 "The batch buffer is full. The position of the message" 

13 f" in the transferred collection at which the overflow occurred: {self.message_position}" 

14 )