Contribution · Spring Kafka · Kotlin Coroutines
Spring Kafka 기여
suspend @KafkaListener + DefaultErrorHandler 조합에서 발견한 두 개의 별개 회귀를 수정했습니다. 각 이슈별 상세 페이지를 따로 두었습니다.
무한 재전송 (GH-4465)
suspend @KafkaListener + DefaultErrorHandler 조합에서 비동기 retry가 무한 재전송되는 회귀를 추적해 원인이 되는 큐 중복을 제거. 회귀 테스트와 함께 머지됐습니다.
두 레코드 silent 유실 (GH-4504)
같은 파티션 두 비동기 실패 레코드가 per-record seek 클로버링으로 earlier-offset 레코드가 silent 유실되던 회귀를 offset-order grouping으로 수정. 후속으로 head-of-line amplification을 linear로 bound하는 PR과 4.0.x backport 회귀 fix-forward PR도 진행 중.
- PR #4505 GH-4504: Fix silent record loss with two failing async records on one partition merged
- PR #4512 GH-4504: Bound async retry to linear delivery count per record open
- PR #4517 4.0.x: Cherry-pick 813f6891 to fix test regressions from the #4505 backport merged
DLT 자동 재처리 API — feature proposal (#4523)
@RetryableTopic 파이프라인에서 DLT 에 들어간 레코드를 framework가 자동으로 retry chain entry로 다시 흘려보내는 first-class API 제안. 자동 재처리 대상은 pluggable policy(DltReplayPolicy)로 결정, 다시 실패한 레코드는 parking queue에 종착시켜 human-review-only로 격리. 모두 opt-in. 2022년 #2172의 후속이며 이번엔 framework 차원 contract로 lift.
- Issue #4523 Feature: First-class DLT replay API (operator-driven re-processing of records after DLT handling) open · awaiting triage