mockafka-py
mockafka-py copied to clipboard
:bug: Fix #149 - Ensure Compatibility with aiokafka ConsumerRecord Headers
This PR addresses issue #149 by enhancing the header handling logic to ensure compatibility with aiokafka's ConsumerRecord. Specifically, the headers are now processed as a 'Sequence[Tuple[str, bytes]]', which aligns with aiokafka's expected format. This change prevents potential errors when dealing with Kafka message headers in the application.