confluent-kafka-python
confluent-kafka-python copied to clipboard
After Decoding mesaage, consumer should return schema ID
Description
If someone wants the schema id of message which consumer is going to consume(after some transformation) then there should be schema ID to serialize the data into schema.
How to reproduce
Instead of returning only the message from decode
function it should also return schema id.