ddrid commented on a change in pull request #11979:
URL: https://github.com/apache/kafka/pull/11979#discussion_r840399831
##########
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##########
@@ -790,7 +781,6 @@ private void adjustSequencesDueToFailedBatch(ProducerBatch
batch) {
throw new IllegalStateException("Sequence number for batch
with sequence " + inFlightBatch.baseSequence()
+ " for partition " + batch.topicPartition + " is
going to become negative: " + newSequence);
- log.info("Resetting sequence number of batch with current sequence
{} for partition {} to {}", inFlightBatch.baseSequence(), batch.topicPartition,
newSequence);
Review comment:
Cause `inFlightBatch.resetProducerState` will be called immediately. I
think this log is duplicate in `resetProducerState` method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
