gistfile1.txt

[2023-12-06 10:16:32,684] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:33,437] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:33,934] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:34,438] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
[2023-12-06 10:16:43,631] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:55,333] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:57,187] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:16:59,138] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:16:59,137] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:03,237] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:06,240] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:14,537] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:17,041] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:26,334] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:29,781] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:33,681] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:33,681] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:42,641] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:52,994] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:17:57,088] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:11,595] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:11,595] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:15,084] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:15,637] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:18:15,384] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:15,432] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:23,545] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:34,332] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:47,086] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:50,688] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:51,938] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:51,938] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:54,189] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:18:54,283] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:26,435] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:38,593] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:44,578] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:43,378] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:43,380] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:19:43,378] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:09,291] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:31,293] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:42,182] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:43,990] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:42,384] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:42,183] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:42,183] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:20:46,032] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:21:14,936] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:21:25,877] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:21:52,426] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:22:02,031] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:21:52,426] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:21:52,426] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:21:52,886] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:22:19,838] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:128)
[2023-12-06 10:22:16,825] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:22:14,180] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:22:33,031] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2023-12-06 10:22:34,741] INFO [Controller id=0] Creating FeatureZNode at path: /feature with contents: FeatureZNode(2,Enabled,Map()) (kafka.controller.KafkaController:66)
[2023-12-06 10:22:41,587] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2023-12-06 10:23:10,876] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2023-12-06 10:23:27,239] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2023-12-06 10:23:27,729] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:23:40,238] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:23:38,877] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:23:28,078] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:23:28,333] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2023-12-06 10:23:58,580] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:24:16,226] INFO [Controller id=0] Initialized broker epochs cache: HashMap(0 -> 26) (kafka.controller.KafkaController:66)
[2023-12-06 10:24:13,382] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:24:21,177] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:24:37,927] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2023-12-06 10:24:47,583] INFO [Controller id=0] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 10:24:50,134] INFO [Controller id=0] Current list of topics in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 10:24:58,330] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2023-12-06 10:24:39,384] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:09,983] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:09,126] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:25:06,027] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2023-12-06 10:25:40,325] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 10:25:46,588] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2023-12-06 10:24:47,583] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:50,637] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2023-12-06 10:25:46,685] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:42,084] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:20,779] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:25:20,438] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:26:14,482] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:39511 (id: 0 rack: rack/0) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:26:03,026] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:26:02,777] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:26:01,288] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2023-12-06 10:25:52,824] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:26:36,534] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 10:26:46,581] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 10:26:48,280] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 10:26:36,533] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:26:30,526] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:39511 (id: 0 rack: rack/0) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:26:51,831] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2023-12-06 10:27:04,580] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
[2023-12-06 10:27:02,627] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:39511 (id: 0 rack: rack/0) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:27:12,083] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2023-12-06 10:27:13,876] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:17,383] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:13,876] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:13,478] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:39511 (id: 0 rack: rack/0) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:27:21,173] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2023-12-06 10:27:17,383] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:17,383] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:32,874] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:51,979] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:53,834] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:27:51,980] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:09,225] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=26, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=39511, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack='rack/0')) to broker localhost:39511 (id: 0 rack: rack/0). Reconnecting to broker. (kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to 0 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:28:14,077] WARN Client session timed out, have not heard from server in 16196ms for session id 0x10083a9a54f0001 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:28:14,076] WARN Client session timed out, have not heard from server in 16196ms for session id 0x10083a9a54f0000 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:28:17,371] WARN Session 0x10083a9a54f0001 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16196ms for session id 0x10083a9a54f0001
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 10:28:17,481] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:17,371] WARN Session 0x10083a9a54f0000 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16196ms for session id 0x10083a9a54f0000
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 10:28:20,671] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:39511 (id: 0 rack: rack/0) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 10:28:20,926] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:29,223] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:32,020] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:37,680] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:28:33,876] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:51,326] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:54,133] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:01,722] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:28:55,973] WARN Client session timed out, have not heard from server in 15198ms for session id 0x10083a9a54f0000 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:29:06,223] WARN Session 0x10083a9a54f0000 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 15198ms for session id 0x10083a9a54f0000
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 10:29:06,223] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:14,171] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:14,171] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:23,421] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:32,880] WARN Session 0x10083a9a54f0001 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
EndOfStreamException: Unable to read additional data from server sessionid 0x10083a9a54f0001, likely server has closed socket
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 10:29:36,869] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0000 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 10:29:43,233] WARN Session 0x10083a9a54f0000 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0000 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 10:29:44,927] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:47,684] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0001 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 10:29:44,927] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:50,827] WARN Session 0x10083a9a54f0001 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0001 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 10:29:49,824] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:29:53,381] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:03,472] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2023-12-06 10:30:11,071] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:16,525] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:28,781] WARN Client session timed out, have not heard from server in 11301ms for session id 0x10083a9a54f0003 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:30:32,175] WARN Session 0x10083a9a54f0003 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 11301ms for session id 0x10083a9a54f0003
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 10:30:36,121] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:35,930] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 2 and epoch zk version is now 2 (kafka.controller.KafkaController:66)
[2023-12-06 10:30:37,628] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:45,381] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2023-12-06 10:30:51,718] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0003 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 10:30:52,775] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:58,223] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:30:56,472] WARN Session 0x10083a9a54f0003 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0003 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 10:30:55,876] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2023-12-06 10:31:05,817] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:10,178] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:08,169] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2023-12-06 10:31:23,829] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:20,374] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:30,324] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2023-12-06 10:31:43,474] INFO [Controller id=0] Initialized broker epochs cache: HashMap(0 -> 50) (kafka.controller.KafkaController:66)
[2023-12-06 10:31:50,326] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 10:31:55,817] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:55,068] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:31:52,368] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2023-12-06 10:32:06,474] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:04,871] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:22,871] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:16,729] INFO [Controller id=0] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 10:32:35,424] INFO [Controller id=0] Current list of topics in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 10:32:38,268] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2023-12-06 10:32:41,627] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:43,421] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2023-12-06 10:32:51,170] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 10:32:54,619] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2023-12-06 10:32:57,273] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2023-12-06 10:32:52,821] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:59,427] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:32:58,919] INFO [Controller id=0] Ready to serve as the new controller with epoch 2 (kafka.controller.KafkaController:66)
[2023-12-06 10:32:56,775] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:33:24,872] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 10:33:23,620] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:33:13,574] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:33:49,427] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:33:29,421] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 10:34:05,969] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 10:34:12,774] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2023-12-06 10:34:16,515] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
[2023-12-06 10:33:25,567] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:34:30,817] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:34:28,023] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2023-12-06 10:34:26,025] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:56:51,459] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:53:10,463] WARN Session 0x10083a9a54f0002 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
EndOfStreamException: Unable to read additional data from server sessionid 0x10083a9a54f0002, likely server has closed socket
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 10:53:01,758] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:52:56,762] WARN Client session timed out, have not heard from server in 1101148ms for session id 0x10083a9a54f0005 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:52:56,762] WARN Client session timed out, have not heard from server in 1105855ms for session id 0x10083a9a54f0004 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 11:02:00,158] WARN Session 0x10083a9a54f0005 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 1101148ms for session id 0x10083a9a54f0005
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:00:56,005] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 11:00:10,702] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:59:49,609] WARN Client session timed out, have not heard from server in 16307ms for session id 0x10083a9a54f0002 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 10:57:50,053] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:57:50,053] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 10:57:02,260] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:08:14,447] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:07:00,454] WARN Session 0x10083a9a54f0002 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16307ms for session id 0x10083a9a54f0002
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:06:20,945] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:06:06,598] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:04:50,553] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:03:56,161] WARN Client session timed out, have not heard from server in 15450ms for session id 0x10083a9a54f0005 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 11:02:33,299] WARN Session 0x10083a9a54f0004 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 1105855ms for session id 0x10083a9a54f0004
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:19:52,163] WARN Session 0x10083a9a54f0005 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 15450ms for session id 0x10083a9a54f0005
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:16:34,420] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:16:32,727] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:13:41,780] WARN [RemoteLogManager=0 partition=R43Knpk9SrqUio5v0IZgyw:Follower-0] Current task for topic-partition R43Knpk9SrqUio5v0IZgyw:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:13:31,623] WARN Client session timed out, have not heard from server in 16514ms for session id 0x10083a9a54f0002 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 12:13:45,720] WARN Session 0x10083a9a54f0002 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16514ms for session id 0x10083a9a54f0002
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:13:17,670] WARN [RemoteLogManager=0 partition=8ry4Guf3QuCslWQztaAHVw:Leader-0] Current task for topic-partition 8ry4Guf3QuCslWQztaAHVw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:45,676] WARN [RemoteLogManager=0 partition=IFOJuT4zQGOebjuJX2NmIQ:Leader-0] Current task for topic-partition IFOJuT4zQGOebjuJX2NmIQ:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:45,669] WARN [RemoteLogManager=0 partition=VHsLU-ReQ_Cm4lVtQci0TA:Leader-0] Current task for topic-partition VHsLU-ReQ_Cm4lVtQci0TA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:45,611] WARN [RemoteLogManager=0 partition=hqJqfymfR6SUiHlNrjOdwg:Leader-0] Current task for topic-partition hqJqfymfR6SUiHlNrjOdwg:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 11:37:26,110] WARN CancelledKeyException causing close of session: 0x10083a9a54f0005 (org.apache.zookeeper.server.NIOServerCnxn:370)
[2023-12-06 11:34:07,706] WARN Client session timed out, have not heard from server in 16711ms for session id 0x10083a9a54f0005 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 12:13:45,721] WARN Session 0x10083a9a54f0005 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16711ms for session id 0x10083a9a54f0005
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:33:14,352] WARN Client session timed out, have not heard from server in 16637ms for session id 0x10083a9a54f0004 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 12:13:45,721] WARN Session 0x10083a9a54f0004 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 16637ms for session id 0x10083a9a54f0004
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 11:32:42,806] WARN [RemoteLogManager=0 partition=i5cfg4VARQC17cJMCbjEzw:Leader-0] Current task for topic-partition i5cfg4VARQC17cJMCbjEzw:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "org.apache.kafka.common.TopicPartition.topic()" because the return value of "kafka.log.UnifiedLog.topicPartition()" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:45,773] WARN [RemoteLogManager=0 partition=konHzmQ8Rk6B4NmkCs9H0A:Follower-0] Current task for topic-partition konHzmQ8Rk6B4NmkCs9H0A:Follower-0 received error but it will be scheduled. Reason: Cannot invoke "scala.Option.isDefined()" because "leaderEpochCacheOpt" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:45,833] ERROR [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Error occurred while copying log segments of partition: ru47vXzwR_uk1ywX3haxtA:Leader-0 (kafka.log.remote.RemoteLogManager$RLMTask:710)
java.lang.NullPointerException: customMetadata can not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:235)
	at org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate.<init>(RemoteLogSegmentMetadataUpdate.java:62)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegment(RemoteLogManager.java:746)
	at kafka.log.remote.RemoteLogManager$RLMTask.copyLogSegmentsToRemote(RemoteLogManager.java:693)
	at kafka.log.remote.RemoteLogManager$RLMTask.run(RemoteLogManager.java:801)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	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)
[2023-12-06 12:13:45,834] WARN [RemoteLogManager=0 partition=ru47vXzwR_uk1ywX3haxtA:Leader-0] Current task for topic-partition ru47vXzwR_uk1ywX3haxtA:Leader-0 received error but it will be scheduled. Reason: Cannot invoke "java.util.Iterator.hasNext()" because "segmentMetadataIter" is null (kafka.log.remote.RemoteLogManager$RLMTask:818)
[2023-12-06 12:13:47,368] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0005 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 12:13:47,368] WARN Session 0x10083a9a54f0005 for server localhost/127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0005 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 12:13:47,538] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0002 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 12:13:47,539] WARN Session 0x10083a9a54f0002 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0002 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 12:13:47,539] ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer:159)
kafka.zookeeper.ZooKeeperClientExpiredException: Session expired either before or while waiting for connection
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:266)
	at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$1(ZooKeeperClient.scala:248)
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:248)
	at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:2082)
	at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1921)
	at kafka.zk.KafkaZkClient.retryRequestUntilConnected(KafkaZkClient.scala:1916)
	at kafka.zk.KafkaZkClient.getChildren(KafkaZkClient.scala:899)
	at kafka.zk.KafkaZkClient.getSortedBrokerList(KafkaZkClient.scala:573)
	at kafka.zk.KafkaZkClient.getAllBrokersInCluster(KafkaZkClient.scala:522)
	at kafka.server.KafkaServer.createBrokerInfo(KafkaServer.scala:708)
	at kafka.server.KafkaServer.startup(KafkaServer.scala:401)
	at kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1(KafkaServerTestHarness.scala:356)
	at kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1$adapted(KafkaServerTestHarness.scala:352)
	at scala.collection.immutable.Vector.foreach(Vector.scala:2124)
	at kafka.integration.KafkaServerTestHarness.createBrokers(KafkaServerTestHarness.scala:352)
	at kafka.integration.KafkaServerTestHarness.setUp(KafkaServerTestHarness.scala:121)
	at kafka.api.IntegrationTestHarness.doSetup(IntegrationTestHarness.scala:134)
	at kafka.server.MetadataRequestTest.setUp(MetadataRequestTest.scala:41)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:128)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:78)
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
	at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:521)
	at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$23(ClassBasedTestDescriptor.java:506)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$3(TestMethodTestDescriptor.java:175)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$6(TestMethodTestDescriptor.java:203)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:203)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:172)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:119)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:94)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:89)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
	at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
	at jdk.proxy1/jdk.proxy1.$Proxy2.stop(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
	at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
[2023-12-06 12:13:47,549] WARN Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0004 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 12:13:47,550] WARN Session 0x10083a9a54f0004 for server /127.0.0.1:40411, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x10083a9a54f0004 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 12:13:47,551] ERROR [Controller id=0] Error processing event ControllerChange (kafka.controller.KafkaController:76)
kafka.zookeeper.ZooKeeperClientExpiredException: Session expired either before or while waiting for connection
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:266)
	at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$1(ZooKeeperClient.scala:248)
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:248)
	at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:2082)
	at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1921)
	at kafka.zk.KafkaZkClient.retryRequestUntilConnected(KafkaZkClient.scala:1916)
	at kafka.zk.KafkaZkClient.registerZNodeChangeHandlerAndCheckExistence(KafkaZkClient.scala:1573)
	at kafka.controller.KafkaController.maybeResign(KafkaController.scala:1540)
	at kafka.controller.KafkaController.processControllerChange(KafkaController.scala:2576)
	at kafka.controller.KafkaController.process(KafkaController.scala:2624)
	at kafka.controller.QueuedEvent.process(ControllerEventManager.scala:54)
	at kafka.controller.ControllerEventManager$ControllerEventThread.process$1(ControllerEventManager.scala:138)
	at kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1(ControllerEventManager.scala:141)
	at kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1$adapted(ControllerEventManager.scala:141)
	at com.yammer.metrics.core.Timer.time(Timer.java:91)
	at kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:141)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 12:13:47,551] ERROR [Controller id=0] Error processing event ReplicaLeaderElection(None,PREFERRED,ZkTriggered,kafka.controller.ReplicaLeaderElection$$$Lambda$1395/0x00000008015f27c0@1dce13ab) (kafka.controller.KafkaController:76)
org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired for /admin/preferred_replica_election
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
	at kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:563)
	at kafka.zk.KafkaZkClient.registerZNodeChangeHandlerAndCheckExistence(KafkaZkClient.scala:1577)
	at kafka.controller.KafkaController.processReplicaLeaderElection(KafkaController.scala:2214)
	at kafka.controller.KafkaController.process(KafkaController.scala:2606)
	at kafka.controller.QueuedEvent.process(ControllerEventManager.scala:54)
	at kafka.controller.ControllerEventManager$ControllerEventThread.process$1(ControllerEventManager.scala:138)
	at kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1(ControllerEventManager.scala:141)
	at kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1$adapted(ControllerEventManager.scala:141)
	at com.yammer.metrics.core.Timer.time(Timer.java:91)
	at kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:141)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 12:13:47,551] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,553] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,579] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 3 and epoch zk version is now 3 (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,580] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,581] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,581] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,582] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,584] INFO [Controller id=0] Initialized broker epochs cache: HashMap(0 -> 61) (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,586] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,586] INFO [Controller id=0] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,586] INFO [Controller id=0] Current list of topics in the cluster: HashSet() (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,586] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,587] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,587] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,587] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,587] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,587] INFO [Controller id=0] Ready to serve as the new controller with epoch 3 (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,588] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,588] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,588] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,588] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,588] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
[2023-12-06 12:13:47,629] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2023-12-06 12:13:49,755] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:86)
[2023-12-06 12:13:49,758] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:143)
[2023-12-06 12:13:49,758] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:105)
[2023-12-06 12:13:49,760] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)