-
Notifications
You must be signed in to change notification settings - Fork 526
Closed
Labels
Description
[2024-02-04 18:19:02,023] ERROR [ReplicaManager broker=1] Unexpected error handling request FetchParams(requestVersion=7, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=30000000, isolation=FetchHighWatermark, clientMetadata= None) ArrayBuffer((AAAAAAAAAAAAAAAAAAAAAA:test_topic-0,PartitionData(topicId=AAAAAAAAAAAAAAAAAAAAAA, fetchOffset=8334, logStartOffset=-1, maxBytes=1048576, currentLeaderEpoch=Optional.empty, lastFetchedEpoch=Optional.empty)), (AAAAAAAAAAAAAAAAAAAAAA:test_topic-5,PartitionData(topicId=AAAAAAAAAAAAAAAAAAAAAA, fetchOffset=8050, logStartOffset=-1, maxBytes=1048576, currentLeaderEpoch=Optional.empty, lastFetchedEpoch=Optional.empty)), (AAAAAAAAAAAAAAAAAAAAAA:test_topic-3,PartitionData(topicId=AAAAAAAAAAAAAAAAAAAAAA, fetchOffset=7350, logStartOffset=-1, maxBytes=1048576, currentLeaderEpoch=Optional.empty, lastFetchedEpoch=Optional.empty)), (AAAAAAAAAAAAAAAAAAAAAA:test_topic-1,PartitionData(topicId=AAAAAAAAAAAAAAAAAAAAAA, fetchOffset=8050, logStartOffset=-1, maxBytes=1048576, currentLeaderEpoch=Optional.empty, lastFetchedEpoch=Optional.empty))) (kafka.server.ReplicaManager)
java.lang.ClassCastException: class org.apache.kafka.common.record.MemoryRecords cannot be cast to class org.apache.kafka.common.record.PooledResource (org.apache.kafka.common.record.MemoryRecords and org.apache.kafka.common.record.PooledResource are in unnamed module of loader 'app')
at kafka.server.KafkaApis.$anonfun$handleFetchRequest$27(KafkaApis.scala:1000)
at java.base/java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:647)
at kafka.server.KafkaApis.release$1(KafkaApis.scala:998)
at kafka.server.KafkaApis.processResponseCallback$1(KafkaApis.scala:1040)
at kafka.server.KafkaApis.$anonfun$handleFetchRequest$34(KafkaApis.scala:1094)
at kafka.server.KafkaApis.$anonfun$handleFetchRequest$34$adapted(KafkaApis.scala:1094)
at kafka.server.ReplicaManager.kafka$server$ReplicaManager$$fetchMessages0(ReplicaManager.scala:1216)
at kafka.server.ReplicaManager$$anon$2.run(ReplicaManager.scala:1146)
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.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)
This may result from empty MemoryRecords.