root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

test

This commit is contained in:
Luke Chen 2024-05-08 13:06:53 +08:00
parent 3c25e02524
commit 3dab6159e8
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/src/main/scala/kafka/log/UnifiedLog.scala
View File

@ -1574,6 +1574,7 @@ class UnifiedLog(@volatile var logStartOffset: Long,
private def deleteRetentionSizeBreachedSegments(): Int = { private def deleteRetentionSizeBreachedSegments(): Int = {
val retentionSize: Long = localRetentionSize(config, remoteLogEnabled()) val retentionSize: Long = localRetentionSize(config, remoteLogEnabled())
System.err.print(s"$name $size ")
if (retentionSize < 0 || size < retentionSize) return 0 if (retentionSize < 0 || size < retentionSize) return 0
var diff = size - retentionSize var diff = size - retentionSize
def shouldDelete(segment: LogSegment, nextSegmentOpt: Option[LogSegment]): Boolean = { def shouldDelete(segment: LogSegment, nextSegmentOpt: Option[LogSegment]): Boolean = {

2
server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java
View File

@ -88,7 +88,6 @@ public abstract class ShutdownableThread extends Thread {
synchronized (this) { synchronized (this) {
if (isRunning()) { if (isRunning()) {
log.info("Shutting down"); log.info("Shutting down");
System.err.println(logPrefix + " shutting down");
shutdownInitiated.countDown(); shutdownInitiated.countDown();
if (isInterruptible) if (isInterruptible)
interrupt(); interrupt();
@ -108,7 +107,6 @@ public abstract class ShutdownableThread extends Thread {
if (isStarted) if (isStarted)
shutdownComplete.await(); shutdownComplete.await();
log.info("Shutdown completed"); log.info("Shutdown completed");
System.err.println(logPrefix + " shutted down");
} }
} }