Apurva Mehta created KAFKA-5897: ----------------------------------- Summary: The producerId can be reset unnecessarily Key: KAFKA-5897 URL: https://issues.apache.org/jira/browse/KAFKA-5897 Project: Kafka Issue Type: Improvement Affects Versions: 0.11.0.0, 1.0.0 Reporter: Apurva Mehta
Currently, we expire batches and reset the producer id in cases where we don't need to. For instance, if a batch which has been previously sent is expired in the accumulator, the producerId is reset (or the transaction aborted) unconditionally. However, if the batch failed with certain error codes like {{NOT_LEADER_FOR_PARTITION}}, etc., which definitively indicate that the write never succeeded, we don't need to reset the producer state since the status of the batch is not in doubt. Essentially, we would like an 'reset based on failure mode' logic which would be a bit smarter. -- This message was sent by Atlassian JIRA (v6.4.14#64029)