processStreamDoc needs to distinguish between "data errors" and unknown failures from produce() calls. An unknown produce() error should propogate the excetion all the way back to the Executor.

https://github.com/10gen/mongo/blob/master/src/mongo/db/modules/enterprise/src/streams/exec/kafka_emit_operator.cpp#L322C8-L322C27