Closed 2rba closed 11 months ago
@logger.error(Deimos::KafkaMessage.decoded(messages)) in the rescue block fails to decode the message and causes wrong exception raised This PR:
@logger.error(Deimos::KafkaMessage.decoded(messages))
Fixes #195
tests added
Thanks so much for the contribution!
Description
@logger.error(Deimos::KafkaMessage.decoded(messages))
in the rescue block fails to decode the message and causes wrong exception raised This PR:Fixes #195
Type of change
How Has This Been Tested?
tests added
Checklist: