Skip to content

Commit 3f9e21a

Browse files
authored
[improve][broker] change to warn log level for ack validation error (apache#24459)
## Motivation The error log https://github.com/apache/pulsar/blob/e7eb7b37a779f9b74b8abf43cf622957663495d1/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java#L757-L758 mostly comes from the client. The client could already receive this error, as seen at https://github.com/apache/pulsar/blob/82237d3684fe506bcb6426b3b23f413422e6e4fb/pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/MessageParser.java#L151-L152 We do not need to print this error log in the broker. Doing so would fill up the broker error logs and make them hard to manage. ## Modification - Change to warn log level for ack validation error
1 parent be385c4 commit 3f9e21a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • pulsar-broker/src/main/java/org/apache/pulsar/broker/service

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -754,7 +754,7 @@ private long getUnAckedCountForBatchIndexLevelEnabled(Position position, int bat
754754

755755
private void checkAckValidationError(CommandAck ack, Position position) {
756756
if (ack.hasValidationError()) {
757-
log.error("[{}] [{}] Received ack for corrupted message at {} - Reason: {}", subscription,
757+
log.warn("[{}] [{}] Received ack for corrupted message at {} - Reason: {}", subscription,
758758
consumerId, position, ack.getValidationError());
759759
}
760760
}

0 commit comments

Comments
 (0)