fix(logger): treat DuplicateSequenceException as expected (#769)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Feb 4, 2024 · 09a7e13 · 09a7e13
1 parent 4da41df
commit 09a7e13
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -1077,7 +1077,8 @@ class ReplicaManager(val config: KafkaConfig,
                    _: RecordTooLargeException |
                    _: RecordBatchTooLargeException |
                    _: CorruptRecordException |
-                   _: KafkaStorageException) =>
+                   _: KafkaStorageException |
+                   _: DuplicateSequenceException) =>
             (topicPartition, LogAppendResult(LogAppendInfo.UnknownLogAppendInfo, Some(e)))
           case rve: RecordValidationException =>
             val logStartOffset = processFailedRecord(topicPartition, rve.invalidException)