KAFKA-6207 : Include start of record when RecordIsTooLarge

[samjawale]

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, I created a new function which will get the first 1KB of the message (if the RecordTooLargeException is occurring), and the same will be logged...

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)

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
No test results found.
--none--

[asfgit]

FAILURE
7975 tests run, 5 skipped, 1 failed.
--none--

[asfgit]

FAILURE
7975 tests run, 5 skipped, 1 failed.
--none--

[asfgit]

SUCCESS
8083 tests run, 5 skipped, 0 failed.
--none--