GitHub user jawalesumit opened a pull request: https://github.com/apache/kafka/pull/4237
KAFKA-6207 : Include start of record when RecordIsTooLarge When a message is too large to be sent (at org.apache.kafka.clients.producer.KafkaProducer#doSend), the RecordTooLargeException should carry the start of the record (for example, the first 1KB) so that the calling application can debug which message caused the error. To resolve this, added functionality to log the first 1Kb of message, if RecordIsTooLarge exception is thrown. Thanks, Sumit Jawale ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) You can merge this pull request into a Git repository by running: $ git pull https://github.com/jawalesumit/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4237.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4237 ---- commit f2fbecfa87ac8152d5ae5d2c73fff3fcdc20e861 Author: jawalesumit <jawalesu...@gmail.com> Date: 2017-11-19T21:19:56Z KAFKA-6207 : Include start of record when RecordIsTooLarge ---- ---