Skip to content

occur exception when consume message from topic  #440

@KaimingWan

Description

@KaimingWan

The broker give the following exception when consume data from topic

[2023-11-10 11:26:20,122] ERROR [ReplicaManager broker=0] Error processing fetch with max size 1048576 from consumer on partition AAAAAAAAAAAAAAAAAAAAAA:example_topic-0: PartitionData(topicId=AAAAAAAAAAAAAAAAAAAAAA, fetchOffset=0, logStartOffset=-1, maxBytes=1048576, currentLeaderEpoch=Optional.empty, lastFetchedEpoch=Optional.empty) (kafka.server.ReplicaManager)
java.lang.UnsupportedOperationException
        at kafka.log.streamaspect.ElasticLogSegment.fetchUpperBoundOffset(ElasticLogSegment.scala:187)
        at kafka.log.LocalLog.addAbortedTransactions(LocalLog.scala:474)
        at kafka.log.streamaspect.ElasticLog.$anonfun$readAsync$5(ElasticLog.scala:353)
        at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
        at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
        at java.base/java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:614)
        at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:653)
        at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
        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:840)

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions