We currently fail the processor and only provide this log message. We'd like to do the following:

1. Improve the error message. Add the size of the message that caused this error to occur
2. Add a DLQ message

The message indicates that this is an error encountered by the broker so we should look here to make changes

https://github.com/10gen/mongo/blob/e8a55b0485af400baef573e7004fc9032156c093/src/mongo/db/modules/enterprise/src/streams/exec/kafka_emit_operator.cpp#L779-L783