FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.
NOTE: If type bytes, the message should not be decoded but sent to consumer callback as is so that the user can then manually decode the message inside consumer callback
Check 001_ConsumerLoop _decode_msgs_and_send function.
NOTE: If type bytes, the message should not be decoded but sent to consumer callback as is so that the user can then manually decode the message inside consumer callback