[2021-01-06 16:37:59,492] WARN (data-plane-kafka-request-handler-131 kafka.server.epoch.LeaderEpochFileCache 70) [LeaderEpochCache test-perf1-9] New epoch en
try EpochEntry(epoch=4, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=4, startOffset=9667122), EpochEntry(epoch=3, star
tOffset=9195729), EpochEntry(epoch=2, startOffset=8348201)). Cache now contains 0 entries.
[2021-01-06 16:37:59,493] WARN (data-plane-kafka-request-handler-131 kafka.server.epoch.LeaderEpochFileCache 70) [LeaderEpochCache test-perf1-8] New epoch en
try EpochEntry(epoch=3, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=3, startOffset=9667478), EpochEntry(epoch=2, star
tOffset=9196127), EpochEntry(epoch=1, startOffset=8342787)). Cache now contains 0 entries.
[2021-01-06 16:37:59,495] WARN (data-plane-kafka-request-handler-131 kafka.server.epoch.LeaderEpochFileCache 70) [LeaderEpochCache test-perf1-2] New epoch en
try EpochEntry(epoch=3, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=3, startOffset=9667478), EpochEntry(epoch=2, star
tOffset=9196127), EpochEntry(epoch=1, startOffset=8336727)). Cache now contains 0 entries.
[2021-01-06 16:37:59,498] ERROR (data-plane-kafka-request-handler-142 kafka.server.ReplicaManager 76) [ReplicaManager broker=1003] Error processing append operation on partition test-perf1-9
java.lang.IllegalArgumentException: Received invalid partition leader epoch entry EpochEntry(epoch=4, startOffset=-3)
        at kafka.server.epoch.LeaderEpochFileCache.assign(LeaderEpochFileCache.scala:67)
        at kafka.server.epoch.LeaderEpochFileCache.assign(LeaderEpochFileCache.scala:59)
        at kafka.log.Log.maybeAssignEpochStartOffset(Log.scala:1268)
        at kafka.log.Log.$anonfun$append$6(Log.scala:1181)
        at kafka.log.Log$$Lambda$935/184936331.accept(Unknown Source)
        at java.lang.Iterable.forEach(Iterable.java:75)
        at kafka.log.Log.$anonfun$append$2(Log.scala:1179)
        at kafka.log.Log.append(Log.scala:2387)
        at kafka.log.Log.appendAsLeader(Log.scala:1050)
        at kafka.cluster.Partition.$anonfun$appendRecordsToLeader$1(Partition.scala:1079)
        at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:1067)
        at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:953)
        at kafka.server.ReplicaManager$$Lambda$1025/1369541490.apply(Unknown Source)
        at scala.collection.StrictOptimizedMapOps.map(StrictOptimizedMapOps.scala:28)
        at scala.collection.StrictOptimizedMapOps.map$(StrictOptimizedMapOps.scala:27)
        at scala.collection.mutable.HashMap.map(HashMap.scala:35)
        at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:941)
        at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:621)
        at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:625)

--
[2021-01-06 16:37:59,503] ERROR (data-plane-kafka-request-handler-145 kafka.server.ReplicaManager 76) [ReplicaManager broker=1003] Error processing append op
eration on partition test-perf1-9
java.lang.IllegalArgumentException: Received invalid partition leader epoch entry EpochEntry(epoch=4, startOffset=-4)
        at kafka.server.epoch.LeaderEpochFileCache.assign(LeaderEpochFileCache.scala:67)
        at kafka.server.epoch.LeaderEpochFileCache.assign(LeaderEpochFileCache.scala:59)
        at kafka.log.Log.maybeAssignEpochStartOffset(Log.scala:1268)
        at kafka.log.Log.$anonfun$append$6(Log.scala:1181)
        at kafka.log.Log$$Lambda$935/184936331.accept(Unknown Source)
        at java.lang.Iterable.forEach(Iterable.java:75)
        at kafka.log.Log.$anonfun$append$2(Log.scala:1179)
        at kafka.log.Log.append(Log.scala:2387)
        at kafka.log.Log.appendAsLeader(Log.scala:1050)
        at kafka.cluster.Partition.$anonfun$appendRecordsToLeader$1(Partition.scala:1079)
        at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:1067)
        at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:953)
        at kafka.server.ReplicaManager$$Lambda$1025/1369541490.apply(Unknown Source)
        at scala.collection.StrictOptimizedMapOps.map(StrictOptimizedMapOps.scala:28)
        at scala.collection.StrictOptimizedMapOps.map$(StrictOptimizedMapOps.scala:27)
        at scala.collection.mutable.HashMap.map(HashMap.scala:35)
        at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:941)
        at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:621)
        at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:625)