Я вижу, например, исключение следующим образом:
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
Iесть только информация об исключении.Я ничего не могу обернуть с try catch
, потому что я использую встроенный в Kafka Flow или Kafka Sink.Возможно, мне придется отказаться от этой интеграции и использовать производителя Kafka вручную, потому что я не вижу другого решения.