GitHub user jawalesumit opened a pull request:
https://github.com/apache/kafka/pull/4235
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/4235.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 #4235
----
commit 6236c3f10076ab6a8e576f9de9caf8cb2ad3200b
Author: jawalesumit <jawalesu...@gmail.com>
Date: 2017-11-19T09:57:41Z
KAFKA-6207 : Include start of record when RecordIsTooLarge
----
---
