This is a relic of old code which was removed and doesn't work (metadata isn't a thing). We should replace this by instantiating a Deimos::KafkaMessage with the given data and calling decoded_message, which doesn't require us to store the decoded message or producer on the message itself.
This is a relic of old code which was removed and doesn't work (
metadataisn't a thing). We should replace this by instantiating aDeimos::KafkaMessagewith the given data and callingdecoded_message, which doesn't require us to store the decoded message or producer on the message itself.