AutoMQ/automq

[BUG] new coordinator load fail

Closed this issue · 0 comments

[2024-03-19 07:58:03,323] ERROR [GroupCoordinator id=2] Failed to load metadata from __consumer_offsets-0 with epoch 2 due to scala.MatchError: kafka.log.streamaspect.ElasticLogFileRecords$BatchIteratorRecordsAdaptor@6627bbcd (of class kafka.log.streamaspect.ElasticLogFileRecords$BatchIteratorRecordsAdaptor). (org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime)
scala.MatchError: kafka.log.streamaspect.ElasticLogFileRecords$BatchIteratorRecordsAdaptor@6627bbcd (of class kafka.log.streamaspect.ElasticLogFileRecords$BatchIteratorRecordsAdaptor)
        at kafka.coordinator.group.CoordinatorLoaderImpl.doLoad(CoordinatorLoaderImpl.scala:114)
        at kafka.coordinator.group.CoordinatorLoaderImpl.$anonfun$load$1(CoordinatorLoaderImpl.scala:69)
        at org.apache.kafka.server.util.KafkaScheduler.lambda$schedule$1(KafkaScheduler.java:150)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        at java.base/java.lang.Thread.run(Thread.java:833)