Created
December 19, 2023 13:41
-
-
Save stanislavkozlovski/cfba15bec612eb552a88c3e35866adbd to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [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) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment