Messages by Thread
-
-
[jira] [Comment Edited] (KAFKA-21034) Wipe global store on start up, when corrupted
Uladzislau Blok (Jira)
-
[jira] [Resolved] (KAFKA-20609) Use the lastModifiedTime to replace furture timestamp in deleting retentions
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20994) Speed up LeaderElectionCommandTest
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-21042) Improve LogCaptureAppender#getMessages and apply the improved one to the codebase
Chang Chi Hsu (Jira)
-
[jira] [Resolved] (KAFKA-21005) Remove hamcrest from org.apache.kafka.streams.kstream.internals package
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21042) Improve LogCaptureAppender#getMessages and apply the improved one to the codebase
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-21038: Move LogManagerBuilder to jmh module [kafka]
via GitHub
-
[PR] MINOR: Upgrade Testcontainers to 2.x for Docker 29 compatibility [kafka]
via GitHub
-
[PR] KAFKA-19339: Move DelayedFetch to server module [kafka]
via GitHub
-
[PR] KAFKA-17719: Recover task configs lost after config topic compaction [kafka]
via GitHub
-
[PR] KAFKA-14218: Replace temp file handler with JUnit 5 @TempDir in generator, tools, and test-common tests [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-21034) Wipe global store on start up, when corrupted
Jira
-
[jira] [Assigned] (KAFKA-21034) Wipe global store on start up, when corrupted
Jira
-
[PR] KAFKA-21036: Migrate LeaderEpochFileCacheTest to storage module [kafka]
via GitHub
-
Re: [PR] Update EndToEndLatency.java [kafka]
via GitHub
-
[PR] KAFKA-18141: Show default user/client-id/ip quotas in kafka-metadata-shell [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21022) Broker Crash During ZK-to-KRaft Migration Due to Missing Topic ID in Empty Log Directory
Rishi Kant Rana (Jira)
-
[PR] MINOR: Avoid unnecessary cluster setup in ListConsumerGroupTest [kafka]
via GitHub
-
[PR] KAFKA-16628: Add system test for static consumer bounce with non-eage… [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21033) Regression in backoff algorithm during streams internal topic create
Hrishi Baskaran (Jira)
-
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
-
Re: [PR] KAFKA-20568: Unify DSL store accessor and header-aware builder naming [kafka]
via GitHub
-
[PR] MINOR: Replace try/fail/catch with assertThrows in DescribeUserScramCredentialsResultTest [kafka]
via GitHub
-
[PR] KAFKA-21037: Migrate AllocateProducerIdsRequestTest to server module [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20745) add tests for OffsetMapTest to verify different hash algorithms?
Ilan Karasik (Jira)
-
[jira] [Assigned] (KAFKA-17429) TopologyTestDriver.close() : The processor is already closed when cache is activated on state store
Gabriel Dutra (Jira)
-
[PR] KAFKA-17429 Avoid dirtying cached entries for unchanged records [kafka]
via GitHub
-
[PR] KAFKA-21011: Declare server as an api dependency of core [kafka]
via GitHub
-
[PR] MINOR: remove unused MockAssignor [kafka]
via GitHub
-
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
-
[PR] KAFKA-21041: Allow equals signs in client metrics match patterns [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21041) ClientMetricsConfigs rejects match patterns whose regex contains an equals sign
cuishuang (Jira)
-
[jira] [Assigned] (KAFKA-19818) Move ClientQuotaMetadataManager to metadata module
majialong (Jira)
-
[jira] [Commented] (KAFKA-19818) Move ClientQuotaMetadataManager to metadata module
majialong (Jira)
-
[jira] [Commented] (KAFKA-21039) Remove hamcrest from KTable* basic tests
majialong (Jira)
-
[jira] [Resolved] (KAFKA-21025) StreamsGroupHeartbeatRequest.Builder does not clear owned warm-up tasks when it negotiates request version 0
Matthias J. Sax (Jira)
-
[PR] KAFKA-21005: Remove hamcrest from org.apache.kafka.streams.kstream.internals package [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21040) Upgrade testcontainers to 2.x so ClientAssertionKeycloakIntegrationTest can run against Docker 29+
Andy Huang (Jira)
-
[jira] [Created] (KAFKA-21040) Upgrade testcontainers to 2.x so ClientAssertionKeycloakIntegrationTest can run against Docker 29+
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20825) Native image can't work due to missing DefaultShareGroupDLQManager
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-21019) Cover consumer and share group protocols in docker sanity tests
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-21039: Remove hamcrest from KTable* basic tests [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21039) Remove hamcrest from KTable* basic tests
Luong Vinh Phu (Jira)
-
[jira] [Created] (KAFKA-21039) Remove hamcrest from KTable* basic tests
Luong Vinh Phu (Jira)
-
[jira] [Assigned] (KAFKA-21038) Move LogManagerBuilder to jmh module
Chang Chi Hsu (Jira)
-
[jira] (KAFKA-20948) Migrate hamcrest tests to JUnit
Luong Vinh Phu (Jira)
-
[jira] [Created] (KAFKA-21038) Move LogManagerBuilder to jmh module
Chia-Ping Tsai (Jira)
-
[jira] [Comment Edited] (KAFKA-20948) Migrate hamcrest tests to JUnit
Luong Vinh Phu (Jira)
-
[jira] [Assigned] (KAFKA-21037) Migrate AllocateProducerIdsRequestTest to server module
dino2895 (Jira)
-
[jira] [Created] (KAFKA-21037) Migrate AllocateProducerIdsRequestTest to server module
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-21036) Migrate LeaderEpochFileCacheTest to storage module
Jheng-Sing Chen (Jira)
-
[jira] [Created] (KAFKA-21036) Migrate LeaderEpochFileCacheTest to storage module
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21035) Utils.atomicMoveWithFallback masks the move failure when the parent directory flush also fails
Li Guo (Jira)
-
[jira] [Commented] (KAFKA-21035) Utils.atomicMoveWithFallback masks the move failure when the parent directory flush also fails
Li Guo (Jira)
-
[jira] [Created] (KAFKA-21034) Wipe global store on start up, when corrupted
Uladzislau Blok (Jira)
-
[jira] [Updated] (KAFKA-21034) Wipe global store on start up, when corrupted
Uladzislau Blok (Jira)
-
[PR] MINOR: Do not mask atomic move failures with flushDir failures in atomicMoveWithFallback [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V
Hrishi Baskaran (Jira)
-
Re: [PR] KAFKA-20889: reject empty group.instance.id values in Kafka Streams. [kafka]
via GitHub
-
Re: [PR] Update README.md [kafka]
via GitHub
-
Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka]
via GitHub
-
[PR] KAFKA-20423: Fix flakiness of testWakeupWithFetchDataAvailable- #22364 [kafka]
via GitHub
-
[PR] KAFKA-21021: fix flkay test test_fencing_static_consumer. [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log
sanghyeok An (Jira)
-
[jira] [Updated] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log
sanghyeok An (Jira)
-
[jira] [Commented] (KAFKA-21009) Consider introducing record header handling policies for Kafka Streams stateful operations
Matthias J. Sax (Jira)
-
[PR] KAFKA-17535: Flaky testCloseNoWait in KafkaConsumerTest for Classic Consumer [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-21033) Regression in backoff algorithm during streams internal topic create
Steven Schlansker (Jira)
-
[PR] KAFKA-20939: disable async dns resolution in streams and connect [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21033) Regression in backoff algorithm during streams internal topic create
Steven Schlansker (Jira)
-
[jira] [Assigned] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied
Matthias J. Sax (Jira)
-
[PR] MINOR: Back off once per round when creating Streams internal topics [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic
Doyeon Kim (Jira)
-
[jira] [Assigned] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally
Ming-Yen Chung (Jira)
-
[PR] MINOR: Remove quotaConfig() from AbstractKafkaConfig [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3, 4.4, 4.5
Ritika Reddy (Jira)
-
[jira] [Resolved] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3, 4.4
Justine Olshan (Jira)
-
[PR] KAFKA-20997: Improve KeyFactory loading [kafka]
via GitHub
-
[PR] refactor [kafka]
via GitHub
-
[PR] KAFKA-21023: Improve the dependency-check configuration [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-21032) Please update kafka-clients.jar to address CVE-2026-59949
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor
Ken Huang (Jira)
-
[jira] [Created] (KAFKA-21032) Please update kafka-clients.jar to address CVE-2026-59949
Joshua Wisniewski (Jira)
-
[jira] [Commented] (KAFKA-21031) Another busy loop happens while a heartbeat is in flight and the heartbeat timer is expired
Lianet Magrans (Jira)
-
Re: [PR] MINOR: Followup Add KIP-1284 into streams upgrade document [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20847) Suppress buffer changelog tombstones carry no record metadata
RITIK KUMAR JAISWAL (Jira)
-
[jira] [Commented] (KAFKA-19828) Intermittent test failures when using chained emit strategy on window close
RITIK KUMAR JAISWAL (Jira)
-
[jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment()
RITIK KUMAR JAISWAL (Jira)
-
[jira] [Resolved] (KAFKA-21002) Remove hamcrest from org.apache.kafka.streams package
Ken Huang (Jira)