[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13750789#comment-13750789 ]
Guozhang Wang commented on KAFKA-998: ------------------------------------- Hello Jason, I think what you need is to return more information to the caller of Producer.send(), since currently it only returns a FailedToSendMessageException: "Failed to send messages after #, tries." For this case I think it is better for you to create a separate JIRA. As for dynamically adjust the batch size upon receiving MessageSizeTooLargeException, I will file a separate JIRA for this. > Producer should not retry on non-recoverable error codes > -------------------------------------------------------- > > Key: KAFKA-998 > URL: https://issues.apache.org/jira/browse/KAFKA-998 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.8, 0.8.1 > Reporter: Joel Koshy > Assignee: Guozhang Wang > Attachments: KAFKA-998.v1.patch > > > Based on a discussion with Guozhang. The producer currently retries on all > error codes (including messagesizetoolarge which is pointless to retry on). > This can slow down the producer unnecessarily. > If at all we want to retry on that error code we would need to retry with a > smaller batch size, but that's a separate discussion. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira