Discussion:
Improve error message when trying to produce message without key for compacted topic
Patrik Kleindl
2018-08-21 10:29:24 UTC
Permalink
Hello

Yesterday we had the following exception:

Exception thrown when sending a message with key='null' and payload='...'
to topic sometopic:: org.apache.kafka.common.errors.CorruptRecordException:
This message has failed its CRC checksum, exceeds the valid size, or is
otherwise corrupt.

The cause was identified with the help of
https://stackoverflow.com/questions/49098274/kafka-stream-get-corruptrecordexception

Is it possible / would it makes sense to open an issue to improve the error
message for this case?
A simple "Message without a key is not valid for a compacted topic" would
suffice and point a user in the right direction.

best regards

Patrik
Matthias J. Sax
2018-08-21 16:35:36 UTC
Permalink
That makes sense to me.

Please file a Jira. Thanks a lot for reporting this issue!

-Matthias
Post by Patrik Kleindl
Hello
Exception thrown when sending a message with key='null' and payload='...'
This message has failed its CRC checksum, exceeds the valid size, or is
otherwise corrupt.
The cause was identified with the help of
https://stackoverflow.com/questions/49098274/kafka-stream-get-corruptrecordexception
Is it possible / would it makes sense to open an issue to improve the error
message for this case?
A simple "Message without a key is not valid for a compacted topic" would
suffice and point a user in the right direction.
best regards
Patrik
Loading...