Kafka 4.2.1 릴리즈

Kafka 4.2.1 Release

Kafka 4.2.1 릴리즈

Kafka Version 4.2.1 Release

Apache Kafka 4.2.1 버전이 릴리즈되었습니다. (2026년 5월 28일)

4.2.1은 4.2.0 이후 약 3개월 만의 패치(버그 수정) 릴리즈예요. 새로운 기능이나 KIP 추가 없이 26개의 JIRA 이슈(개선 3건, 버그 16건, 그 외 태스크·서브태스크 7건)를 해결했어요. 어떤 부분이 수정되었는지 영역별로 안내해 드릴게요.

Broker / Controller

[KAFKA-20322] — TransactionMarkerChannelManager has discoverBrokerVersions=false causing UnsupportedVersionException during rolling upgrades

• 트랜잭션 마커를 보내는 채널이 상대 브로커의 지원 API 버전을 협상하지 않도록(discoverBrokerVersions=false) 설정돼 있어, 버전이 섞이는 롤링 업그레이드 구간에서 UnsupportedVersionException이 발생하던 문제를 고쳤어요. 트랜잭션을 사용하는 클러스터의 무중단 업그레이드 안정성에 영향이 있어요.

[KAFKA-20380] — controller.quorum.voters should act as advertised.listeners if the latter is not defined

• KRaft에서 advertised.listeners가 정의되지 않은 경우 controller.quorum.voters에 적힌 주소를 advertised listener로 사용하도록 동작을 정리했어요.

[KAFKA-20247] — ControllerRegistrationManager does not retry registration after timing out

• 브로커가 컨트롤러에 등록할 때 타임아웃이 발생하면 재시도하지 않아 등록이 누락되던 문제를 고쳤어요.

[KAFKA-20302] — Receive buffers allocated from MemoryPool may not be released if request is invalid

• 잘못된 요청을 받은 경우 MemoryPool에서 할당한 수신 버퍼가 반환되지 않아 메모리가 새던 문제를 고쳤어요.

[KAFKA-19851] — Delete dynamic config that were removed by Kafka

• Kafka가 더 이상 사용하지 않게 된(제거된) 설정이 동적 설정 저장소에 남아 있던 것을 정리하도록 했어요.

Clients / Consumer

[KAFKA-20165] — Consumer poll may fail with unrecoverable KafkaException if topic not in metadata when fetching committed offsets

• 커밋된 오프셋을 조회할 때 대상 토픽이 아직 메타데이터에 없으면 복구 불가능한 KafkaException으로 poll()이 실패하던 문제를 고쳤어요.

[KAFKA-20131] — ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls

• classic 컨슈머가 LIST_OFFSETS 호출에 실패했을 때 endOffsetRequested 플래그를 초기화하지 않아 이후 동작에 영향을 주던 문제를 고쳤어요.

[KAFKA-20332] — Ensure app thread not collecting records for partitions being revoked

• 리밸런스로 회수(revoke)되는 중인 파티션의 레코드를 애플리케이션 스레드가 계속 수집하지 않도록 했어요.

[KAFKA-20393] — Kafka client send to wong IP caused by stickyNode in TelemetrySender

• 클라이언트 텔레메트리(TelemetrySender)의 stickyNode 처리 때문에 클라이언트가 잘못된 IP로 요청을 보내던 문제를 고쳤어요.

Share Groups (KIP-932)

[KAFKA-20505] — Deadlock in KIP-932 share path

• share 그룹 경로에서 SharePartition.rollbackOrProcessStateUpdates가 write lock을 쥔 채로 future를 완료하면서, 요청 핸들러가 이미 잡고 있던 DelayedOperation lock을 다시 획득하려다 데드락이 발생하던 문제를 고쳤어요.

[KAFKA-20183] — Share consumer group fails when group ID contains colon character

• share 컨슈머 그룹 ID에 콜론(:)이 포함되면 그룹이 동작하지 않던 문제를 고쳤어요.

[KAFKA-20309] — Too many SharePollEvents created

• share 컨슈머에서 SharePollEvent가 과도하게 생성되던 문제를 고쳤어요.

[KAFKA-20034] — DeliveryCompleteCount should be 0 when share group offsets are altered

• share 그룹 오프셋을 변경(alter)했을 때 DeliveryCompleteCount 메트릭이 0으로 보고되도록 정정했어요.

Kafka Streams

[KAFKA-20398] — Memory leak when stream threads are replaced

• stream thread가 교체될 때 메모리가 누수되던 문제를 고쳤어요.

[KAFKA-20254] — Streams group replay fails after log compaction removes classic group tombstone

• 로그 컴팩션으로 classic 그룹 tombstone이 제거된 뒤 Streams 그룹 상태 replay가 실패하던 문제를 고쳤어요.

[KAFKA-20306] — StreamsGroupCommand does not display committed offsets for repartition topics

• kafka-streams-groups 명령이 repartition 토픽의 커밋 오프셋을 표시하지 않던 문제를 고쳤어요.

Kafka Connect

[KAFKA-19697] — NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close()

• Connect 메트릭 그룹(ConnectMetrics$MetricGroup)을 close할 때 발생하던 NPE를 고쳤어요.

[KAFKA-20572] — Connect REST server throws NPE on startup when using listener-prefixed SSL configs

• listener prefix가 붙은 SSL 설정을 사용할 때 Connect REST 서버가 기동 중 NPE를 던지던 문제를 고쳤어요.

보안 및 의존성 업데이트

[KAFKA-20344] — upgrade jetty to 12.0.34

[KAFKA-20373] — CVE-2025–67030 in plexus-utils-3.5.1.jar

[KAFKA-20241] — Jackson core vulnerability GHSA-72hv-8253–57q

[KAFKA-20446] — Native image contains CVE-2026–28390 in libcrypto3 and libssl3

[KAFKA-20447] — Native image contains CVE-2026–22184 in zlib

• 의존성 취약점 대응으로 Jetty를 12.0.34로 올리고, plexus-utils(CVE-2025–67030)와 Jackson(GHSA-72hv-8253–57qq) 취약점을 해소했어요. 네이티브 이미지에 포함된 libcrypto3/libssl3(CVE-2026–28390), zlib(CVE-2026–22184) 취약점도 함께 처리했어요.

더 자세한 정보는 아래 Release Notes를 참고하세요.

• downloads.apache.org/kafka/4.2.1/RELEASE_NOTES.html