김빌 Bill Kim

suspend @KafkaListener + DefaultErrorHandler 조합에서 비동기 retry가 무한 재전송되는 회귀(#4254)의 원인을 추적해 큐 중복을 제거했습니다. 버그를 재현하는 회귀 테스트를 함께 보냈습니다.

자세히 보기 →

• PR #4469 GH-4465: Fix unbounded async retry re-delivery merged

같은 파티션의 두 레코드가 같이 비동기 실패하면 earlier-offset 레코드가 한 번만 invoke되고 recoverer에 도달하지 못해 silent 유실되는 회귀. handleAsyncFailure가 같은 파티션 실패들을 도착 순서로 처리하면서 뒤 호출의 seek가 앞 호출의 seek를 덮어쓰던 문제를, offset 순 정렬 + partition-in-retry skip으로 수정. 후속으로 head-of-line amplification(burst quadratic)을 linear로 bound하는 PR과 4.0.x backport 회귀 fix 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 merged
• PR #4517 4.0.x: Cherry-pick 813f6891 to fix test regressions from the #4505 backport merged

@RetryableTopic 파이프라인에서 DLT에 안착한 레코드를 framework가 자동으로 retry chain entry로 다시 흘려보내는 first-class API 제안. eligibility policy(DltReplayPolicy)로 자동 재처리 대상 결정, cap 초과한 레코드는 parking queue에 종착시켜 human-only 검토 대상으로 격리. 모두 opt-in. 2022년 #2172가 'DIY로 하세요'로 닫혔던 use case를 framework 차원 contract로 lift.

자세히 보기 →

• Issue #4523 First-class DLT replay API — feature proposal (type: enhancement) open · awaiting triage

Strimzi 조직에 보낸 네 건의 정리 — strimzi-kafka-operator 세 건과 kafka-access-operator 한 건. (1) GH-12847 — KafkaCluster만 IOException → RuntimeException으로 던지고, CruiseControl·ClusterCa는 warning 로그 후 빈 secret data / null CertAndKey로 진행하던 비대칭을 통일 (KafkaExporter 등 호출자 NPE 차단). (2) GH-12442 — Cluster Operator의 Cruise Control 클라이언트가 CC 서버 공개키를 핀하던 트러스트를 Cluster CA 기반으로 전환해 CA 롤 + 서버 cert 회전 사이 신뢰 불일치 제거. (3) GH-12870 — MirrorMaker 2 Grafana 대시보드 replication-consumer lag 패널이 Strimzi Metrics Reporter 환경에서 라벨 표기(clientid → client_id) 미스매치로 빈 그래프를 그리던 것을 SMR 컨벤션으로 정정. (4) kafka-access-operator GH-124 — KafkaListener가 ssl.truststore.crt에 Cluster CA Secret의 ca.crt만 담아 CA 키 교체 중 이전/신규 CA 중 한쪽만 신뢰하던 문제를 모든 .crt 엔트리 번들로 수정 (chain 항목은 trust anchor만).

자세히 보기 →

• PR #12884 Unify IOException handling in cert generation paths merged
• PR #12885 Use Cluster CA to establish trust in Cruise Control client in CO merged
• PR #12889 Fix MM2 Grafana dashboards for Strimzi Metrics Reporter merged
• KAO PR #143 Bundle all cluster CAs in ssl.truststore.crt open · awaiting triage

Kafka Connect 전반에 퍼져 있던 ByteBuffer.array() 오용을 추적해 일관된 수정안을 제출했습니다. 직접 버퍼/슬라이스 버퍼 둘 다에서 안전하게 동작하도록 4개 컴포넌트에 같은 계열의 패치를 분리해 올렸습니다.

자세히 보기 →

• PR #22536 KAFKA-20656 — Struct honors ByteBuffer remaining bytes open
• PR #22535 KAFKA-20666 — Offset backing stores honor ByteBuffer remaining bytes open

PR마다 PMD Copy/Paste Detector를 돌리는 GitHub Actions 워크플로를 추가했습니다. 기존 spotbugs.yml과 트리거/구조를 맞추고 CPD 결과를 아티팩트로 업로드합니다.

자세히 보기 →

• PR #17624 [#14185] Add GitHub workflow for PMD Copy/Paste Detector merged

Spring Cloud AWS 3.x SQS 컨테이너에 IGNORE QueueNotFoundStrategy를 추가해, 큐가 없을 때 listener를 조용히 skip하고 application context 부팅을 차단하지 않도록 복원했습니다. 2.x spring-cloud-starter-aws-messaging의 기본 동작을 typed exception을 도입해 FAIL / CREATE / RetryableTopic 경로를 손대지 않고 분리해 적용했습니다.

자세히 보기 →

• PR #1640 GH-1143 Add IGNORE QueueNotFoundStrategy option for SQS open
• PR #1639 GH-1220 Document HTTP proxy configuration for AWS clients open
• PR #1654 GH-1634 Fix duplicate DeleteMessageBatchRequestEntry ids on SQS redelivery within one ack batch merged

contrib/btree_gist의 float4/float8 opclass가 raw C ==/ 연산자를 그대로 써서 IEEE 754 NaN을 잘못 처리. EXCLUDE 제약이 NaN 중복을 허용, RLS 정책이 NaN 행을 누수, GiST index scan이 같은 쿼리에 대해 seq scan과 다른 결과를 반환. utils/float.h의 NaN-aware float{4,8}_* / float{4,8}_cmp_internal()로 교체해 regular btree opclass와 같은 total order로 맞춤. core 245/245 + contrib 48 modules 전체 make check 통과. PostgreSQL은 GitHub PR을 안 받아서 pgsql-bugs 메일링리스트로 클레임 발송, upstream에 merged.

자세히 보기 →

• [1] commit 7d344896 contrib/btree_gist NaN fix — merged by Tom Lane merged
• [2] commit e42d4a1 config.sgml varlistentry attribute consistency — merged by Daniel Gustafsson merged

JpaEventPublicationAdapter#getStatus()가 영속 상태 대신 메모리 값을 돌려주던 버그를 수정했습니다. JdbcEventPublicationRepositoryV2가 이미 적용 중인 패턴과 동일하게 맞추고 markFailed 라운드트립 회귀 테스트를 추가했습니다.

자세히 보기 →

• PR #1714 GH-1683 — Return persisted status from JpaEventPublicationAdapter#getStatus closed

스트리밍 응답에서 observation의 stop order가 잘못된 순서로 호출되는 이슈(#5971)에 대해 실패하는 회귀 테스트를 먼저 PR로 보냈습니다.

자세히 보기 →

• PR #6317 GH-5971: Add failing regression test for streaming observation stop order open

Lombok @Builder 스타일 fluent setter의 속성명이 JavaBean accessor와 어긋나, 두 번째 글자가 대문자인 필드의 매핑이 누락되던 #4000 버그를 DefaultAccessorNamingStrategy에서 수정했습니다. 회귀 테스트를 함께 보냈습니다.

자세히 보기 →

• PR #4074 #4000 Fix property name resolution for fluent setters whose second character is upper case open