MM2 Stops Replicating on Corrupt Record – Need Guidance for Active/Active Setup

[mmuehlbeyer]

need to check in details later on

though did you check this one

Mirror Maker 2 connector trying to write bigger messages than origin

Hi Daniel, You are absolutely right! I was configuring the compression at topic level, and the broker detected a bigger message that it can handle before compressing, hence the error I shown. I was thinking that if the compressed message fits in the topic, the broker must accept it but that doesn’t seem to be the case. Setting the compression in the producer of the worker solved the problem. To make this property easier to set only by the topics that need compression, I allowed it to be overr…

there is a similar issue reported which is related to compressed messages
could this also be the same for you?