This is something we’re aware of and have a couple of issues open to address. The ideal approach is that we implement dead letter queues for elastic where we take the parts of a message that can’t be parsed and drop them
2 Likes