akka - Akka Streams Kafka 错误处理 - 访问导致 Kafka Producer 出现问题的元素

Question

例如，我看到这样的异常：

org.apache.kafka.common.errors.RecordTooLargeException: The message is 10000190 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.

有没有办法了解更多关于导致此异常的 ProducerRecord 的信息？

在Supervisor或recoverWith我只有关于异常的信息。我不能用 包装任何东西try catch，因为我使用的是内置的 Kafka Flow 或 Kafka Sink。可能我需要放弃这种集成并手动使用 Kafka 生产者，因为我看不到其他解决方案。