Обработка ошибок Akka Streams Kafka - доступ к элементу, вызвавшему проблему в Kafka Producer - PullRequest
0 голосов
/ 01 апреля 2019

Я вижу, например, исключение следующим образом:

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 вручную, потому что я не вижу другого решения.

...