jira
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/03/05
[jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
Alieh Saeedi (Jira)
2026/03/05
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
2026/03/05
[jira] [Assigned] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore
Alieh Saeedi (Jira)
2026/03/05
[jira] [Created] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore
Alieh Saeedi (Jira)
2026/03/05
[jira] [Created] (KAFKA-20262) Changelog tombstone records drop custom headers when using headers-aware state stores
TengYao Chi (Jira)
2026/03/05
[PR] KAFKA-20254: Add upgrade guide warning about classic to streams group migration in 4.2.0 [kafka]
via GitHub
2026/03/05
[jira] [Created] (KAFKA-20261) Upgrade path for plain window store to headers store
Alieh Saeedi (Jira)
2026/03/05
[jira] [Created] (KAFKA-20260) Upgrade path from plain KV store to headers store
Alieh Saeedi (Jira)
2026/03/05
[jira] [Created] (KAFKA-20259) Verify IQv1 and IQv2 does not break
Alieh Saeedi (Jira)
2026/03/05
[jira] [Closed] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat
Alieh Saeedi (Jira)
2026/03/05
[jira] [Resolved] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat
Alieh Saeedi (Jira)
2026/03/05
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/05
[jira] [Created] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat
Alieh Saeedi (Jira)
2026/03/05
[jira] [Assigned] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
Alieh Saeedi (Jira)
2026/03/05
[jira] [Assigned] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
2026/03/05
[jira] [Created] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl
Nicholas Telford (Jira)
2026/03/05
[jira] [Updated] (KAFKA-20245) Implementation for dead-letter queues for share groups in Share Partition
Sushant Mahajan (Jira)
2026/03/05
[jira] [Created] (KAFKA-20256) DLQManager interace and default impl
Sushant Mahajan (Jira)
2026/03/05
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/05
[jira] [Created] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat
Alieh Saeedi (Jira)
2026/03/05
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka]
via GitHub
2026/03/05
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/05
[jira] [Resolved] (KAFKA-20132) Implement TimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
2026/03/05
[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate
Yu Xiao (Jira)
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
2026/03/04
[jira] [Assigned] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics
Mahesh Sambaram (Jira)
2026/03/04
Re: [PR] KAFKA-20205: Refactor serialization and deserialization code for *WithHeaders types [kafka]
via GitHub
2026/03/04
[PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] Update EndToEndLatency.java [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19830 [1/N]: refactor KafkaRaftClient to use event-based scheduling [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams (WIP) [kafka]
via GitHub
2026/03/04
Re: [PR] fix: replace 12 bare except clauses with except Exception [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/04
[PR] MINOR: AbstractSegments should not swallow exceptions [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/04
[jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication
Kirk True (Jira)
2026/03/04
Re: [PR] KAFKA-20090: rotate producerId when epoch exhausted during transaction completion. [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
[jira] [Updated] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone
Matthias J. Sax (Jira)
2026/03/04
[jira] [Updated] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone
Matthias J. Sax (Jira)
2026/03/04
[jira] [Created] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone
Lucas Brutschy (Jira)
2026/03/04
[PR] MINOR: version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka]
via GitHub
2026/03/04
[PR] Rlm [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka]
via GitHub
2026/03/04
[jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication
Jira
2026/03/04
[jira] [Created] (KAFKA-20253) High CPU loop on consumer after failed re-authentication
Jira
2026/03/04
[PR] KAFKA-20162: Validation and enforcement of group configurations [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
2026/03/04
[jira] [Commented] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
2026/03/04
[jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
2026/03/04
[jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
[jira] [Resolved] (KAFKA-20158) Implement SessionStoreWithHeaders
Bill Bejeck (Jira)
2026/03/04
[PR] KAFKA-20207: handle the ClusterIdRecord as part of the metadata image [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka]
via GitHub
2026/03/04
[jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Ken Huang (Jira)
2026/03/04
[PR] MINOR: Ignore unassigned records in MockConsumer [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: Fix off-by-one in ShareCoordinatorShard snapshot update count [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
2026/03/04
[PR] MINOR: make processMessages task outputs relocatable for build cache [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
2026/03/04
Re: [PR] MINOR: fix protocol link in templates.py [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka]
via GitHub
2026/03/04
[jira] [Resolved] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq
Mickael Maison (Jira)
2026/03/04
Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka]
via GitHub
2026/03/04
[PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka]
via GitHub
2026/03/04
[jira] [Assigned] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq
Mickael Maison (Jira)
2026/03/04
[PR] MINOR: fix protocol link in templates.py [kafka]
via GitHub
2026/03/04
[jira] [Updated] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq
Chia-Ping Tsai (Jira)
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/03/04
[jira] [Commented] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils
Kartikay Dubey (Jira)
2026/03/04
[jira] [Assigned] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils
Kartikay Dubey (Jira)
2026/03/04
Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka]
via GitHub
2026/03/04
[PR] KAFKA-20251: Add configs for assignment batching and offload [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20178 Move LogCleanerIntegrationTest from core to storage [kafka]
via GitHub
2026/03/04
[jira] [Created] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils
Maros Orsak (Jira)
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
[jira] [Created] (KAFKA-20251) Add assignment batching and offload configs
Sean Quah (Jira)
2026/03/04
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20178 Move LogCleanerIntegrationTest from core to storage [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka]
via GitHub
2026/03/04
Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka]
via GitHub
2026/03/04
[jira] [Assigned] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode
Karl Sorensen (Jira)
2026/03/04
Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka]
via GitHub
2026/03/04
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries [kafka]
via GitHub
2026/03/03
[jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Chia-Ping Tsai (Jira)
2026/03/03
[jira] [Commented] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread
Nilesh Kumar (Jira)
2026/03/03
[jira] [Assigned] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread
Nilesh Kumar (Jira)
2026/03/03
Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-19921 : Test-Common | Fixed order of arguments of assertEquals in unit tests [kafka]
via GitHub
2026/03/03
Re: [PR] Update README.md [kafka]
via GitHub
2026/03/03
Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka]
via GitHub
2026/03/03
[jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure
Yin Lei (Jira)
2026/03/03
Re: [PR] KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: add test cases for dumpLogSegments [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: Move KRaftMetadataCachePublisher to metadata module and convert to Java [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
2026/03/03
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
2026/03/03
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/03
[PR] KAFKA-20205: Refactor serialization and deserialization code for *WithHeaders types [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
2026/03/03
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
2026/03/03
Re: [PR] kAFKA-9651:handling 0 partitions [kafka]
via GitHub
2026/03/03
Re: [PR] kAFKA-9651:handling 0 partitions [kafka]
via GitHub
2026/03/03
[PR] fix: replace printStackTrace() with proper logging in KafkaStreamsNamedTopologyWrapper [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka]
via GitHub
2026/03/03
Re: [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka]
via GitHub
Earlier messages
Later messages