This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new d1deb3075d8 MINOR: Fix malformed UnifiedLog log messages (#22771)
d1deb3075d8 is described below
commit d1deb3075d8bdb28732898506b72429159c02a42
Author: CoderBruis <[email protected]>
AuthorDate: Tue Jul 7 18:44:28 2026 +0800
MINOR: Fix malformed UnifiedLog log messages (#22771)
Reviewers: Ken Huang <[email protected]>, Mickael Maison
<[email protected]>
---
.../main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java
b/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java
index f5e1f8de59e..affa31076ec 100644
---
a/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java
+++
b/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java
@@ -1180,7 +1180,7 @@ public class UnifiedLog implements AutoCloseable {
// to be consistent with
pre-compression bytesRejectedRate recording
brokerTopicStats.topicStats(topicPartition().topic()).bytesRejectedRate().mark(records.sizeInBytes());
brokerTopicStats.allTopicsStats().bytesRejectedRate().mark(records.sizeInBytes());
- throw new
RecordTooLargeException("Message batch size is " + batch.sizeInBytes() + "
bytes in append to" +
+ throw new
RecordTooLargeException("Message batch size is " + batch.sizeInBytes() + "
bytes in append to " +
"partition " +
topicPartition() + " which exceeds the maximum configured size of " +
config().maxMessageSize() + ".");
}
});
@@ -2151,7 +2151,7 @@ public class UnifiedLog implements AutoCloseable {
long maxOffsetInMessages = appendInfo.lastOffset();
if (segment.shouldRoll(new RollParams(config().maxSegmentMs(),
config().segmentSize(), appendInfo.maxTimestamp(), appendInfo.lastOffset(),
messagesSize, now))) {
- logger.debug("Rolling new log segment (log_size = {}/{}}, " +
+ logger.debug("Rolling new log segment (log_size = {}/{}, " +
"offset_index_size = {}/{}, " +
"time_index_size = {}/{}, " +
"inactive_time_ms = {}/{}).",
