i think issue was RecordTooLargeException with this one
(Mirror Maker 2 connector trying to write bigger messages than origin - #3 by kuro)
and we are facing completely different exception CorruptRecordException
“message”:“Failure during poll.”,
“stacktrace”:“org.apache.kafka.common.errors.CorruptRecordException: Invalid magic found in record: 10”}
i am not sure if both issues are relatable or not?