[ 
https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610999#comment-16610999
 ] 

ASF GitHub Bot commented on KAFKA-7332:
---------------------------------------

omkreddy opened a new pull request #5638: KAFKA-7332: Update CORRUPT_MESSAGE 
exception message description
URL: https://github.com/apache/kafka/pull/5638
 
 
   
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


> Improve error message when trying to produce message without key for 
> compacted topic
> ------------------------------------------------------------------------------------
>
>                 Key: KAFKA-7332
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7332
>             Project: Kafka
>          Issue Type: Improvement
>          Components: producer 
>    Affects Versions: 1.1.0
>            Reporter: Patrik Kleindl
>            Priority: Trivial
>
> Goal:
> Return a specific error message like e.g. "Message without a key is not valid 
> for a compacted topic" when trying to produce such a message instead of a 
> CorruptRecordException.
>  
> > 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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to