Skip to content

KAFKA-16202: Extra dot in error message in producer #15296

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
chia7712 merged 6 commits into from
Mar 7, 2024
Merged

KAFKA-16202: Extra dot in error message in producer #15296

Changes from 4 commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
ec84fa3
Omit a dot in the complete error message
infantlikesprogramming Jan 31, 2024
1e21dde
Merge branch 'trunk' into producer-error-message-StorageError
infantlikesprogramming Feb 1, 2024
07e3a63
Merge branch 'apache:trunk' into producer-error-message-StorageError
infantlikesprogramming Feb 9, 2024
891977b
add code to make appropriate change to the error message in case it e…
infantlikesprogramming Feb 9, 2024
39b64da
Editted log message to simply code. Added dots to "defaultExceptionSt…
infantlikesprogramming Feb 16, 2024
847f2bb
Merge branch 'apache:trunk' into producer-error-message-StorageError
infantlikesprogramming Feb 16, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -704,9 +704,10 @@ private void completeBatch(ProducerBatch batch, ProduceResponse.PartitionRespons
"topic-partition may not exist or the user may not have Describe access to it",
batch.topicPartition);
} else {
log.warn("Received invalid metadata error in produce request on partition {} due to {}. Going " +
"to request metadata update now", batch.topicPartition,
error.exception(response.errorMessage).toString());
String errorMessage = error.exception(response.errorMessage).toString();
errorMessage = (errorMessage.endsWith(".")) ? errorMessage : (errorMessage + ".");
log.warn("Received invalid metadata error in produce request on partition {} due to {} Going " +
"to request metadata update now", batch.topicPartition, errorMessage);
}
if (error.exception() instanceof NotLeaderOrFollowerException || error.exception() instanceof FencedLeaderEpochException) {
log.debug("For {}, received error {}, with leaderIdAndEpoch {}", batch.topicPartition, error, response.currentLeader);
Expand Down