Skip to content

Commit 75469d9

Browse files
committed
fix: 수정된 DLT 파티션 처리 로직
1 parent 88f8d6c commit 75469d9

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

modules/kafka/src/main/java/com/loopers/confg/kafka/KafkaConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public DeadLetterPublishingRecoverer deadLetterPublishingRecoverer(KafkaTemplate
6969
record.topic(), record.partition(), record.offset(), record.key(), exception);
7070
return new org.apache.kafka.common.TopicPartition(
7171
record.topic() + ".DLT",
72-
record.partition()
72+
-1
7373
);
7474
});
7575
}

0 commit comments

Comments
 (0)