aiokafka
aiokafka copied to clipboard
[QUESTION] Different value/key deserializer for different topics
Hi all,
According to the docs AIOKafkaConsumer can be created with multiple topics - however only one deserializer can be passed for value/key. Assuming we have topics with different message types, what would be the best practice here? One AIOKafkaConsumer foreach topic+deserializer?
Thanks in advance for your time and help!