[2023-09-27 13:12:39,362] INFO Created log for partition observability-topic-20 in /new-kafka-logs1/kafka/observability-topic-20.f7847e2b76d14085a83071ce84814c8a-future with properties {cleanup.policy=compact, min.insync.replicas=2} (kafka.log.LogManager)
[2023-09-27 13:12:40,152] INFO Attempting to replace current log Log(dir=/kafka-logs3/kafka/observability-topic-20, topicId=NRrj6JT-SlSQZqagNbG0Sw, topic=observability-topic, partition=20, highWatermark=486559, lastStableOffset=486559, logStartOffset=0, logEndOffset=486559) with Log(dir=/csi-kafka-logs1/kafka/observability-topic-20.f7847e2b76d14085a83071ce84814c8a-future, topicId=NRrj6JT-SlSQZqagNbG0Sw, topic=observability-topic, partition=20, highWatermark=486559, lastStableOffset=486559, logStartOffset=0, logEndOffset=486559) for observability-topic-20 (kafka.log.LogManager)
[2023-09-27 13:12:40,155] ERROR Error while flushing log for observability-topic-20 in dir /new-kafka-logs1/kafka with offset 485303 (exclusive) and recovery point 485303 (kafka.server.LogDirFailureChannel)
java.nio.file.NoSuchFileException: /new-kafka-logs1/kafka/observability-topic-20.f7847e2b76d14085a83071ce84814c8a-future
	at java.base/sun.nio.fs.UnixException.translateToIOException(UnixException.java:92)
	at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:106)
	at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
	at java.base/sun.nio.fs.UnixFileSystemProvider.newFileChannel(UnixFileSystemProvider.java:181)
	at java.base/java.nio.channels.FileChannel.open(FileChannel.java:298)
	at java.base/java.nio.channels.FileChannel.open(FileChannel.java:357)
	at org.apache.kafka.common.utils.Utils.flushDir(Utils.java:972)
	at kafka.log.LocalLog.flush(LocalLog.scala:177)
	at kafka.log.UnifiedLog.$anonfun$flush$2(UnifiedLog.scala:1585)
	at kafka.log.UnifiedLog.flush(UnifiedLog.scala:1772)
	at kafka.log.UnifiedLog.flushUptoOffsetExclusive(UnifiedLog.scala:1566)
	at kafka.log.UnifiedLog.$anonfun$roll$1(UnifiedLog.scala:1547)
	at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:116)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)