jira  

Messages by Date

• 2026/02/28 [jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode M Paget (Jira)
• 2026/02/28 [jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode Bertalan Kondrat (Jira)
• 2026/02/28 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-20204: Remove partition-level `ExpiresPerSec` metrics when the broker no longer owns the partition [kafka] via GitHub
• 2026/02/28 [jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode Chia-Ping Tsai (Jira)
• 2026/02/28 Re: [PR] KAFKA-20204: Remove partition-level `ExpiresPerSec` metrics when the broker no longer owns the partition [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka] via GitHub
• 2026/02/28 [jira] [Assigned] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric Lan Ding (Jira)
• 2026/02/28 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/28 [jira] [Created] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric Chia-Ping Tsai (Jira)
• 2026/02/28 [jira] [Updated] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric Chia-Ping Tsai (Jira)
• 2026/02/28 Re: [PR] KAFKA-15583: Enforce HWM advance only if partition is not under-min-ISR [kafka] via GitHub
• 2026/02/28 [PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka] via GitHub
• 2026/02/28 [jira] [Commented] (KAFKA-13819) Add application.server to Streams assignor logs when set Kartikay Dubey (Jira)
• 2026/02/28 [PR] Dddress KAFKA-13819 [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka] via GitHub
• 2026/02/28 [PR] MINOR: Fix typo 'overidden' to 'overridden' in produce_consume_validate.py [kafka] via GitHub
• 2026/02/28 [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka] via GitHub
• 2026/02/28 Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka] via GitHub
• 2026/02/27 [PR] KAFKA-20235: Replace System.out.println with proper logger for missing property file warning [kafka] via GitHub
• 2026/02/27 [jira] [Updated] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning highluck (Jira)
• 2026/02/27 [jira] [Created] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning highluck (Jira)
• 2026/02/27 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• 2026/02/27 [jira] [Updated] (KAFKA-20218) Add downgrade tests in TimestampedKeyValueStoreWithHeadersTest Matthias J. Sax (Jira)
• 2026/02/27 Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20157 Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka] via GitHub
• 2026/02/27 Re: [PR] Add KafkaTopicCalculator feature [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-19914: Move AlterPartitionManager to server module [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-20201: Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type [kafka] via GitHub
• 2026/02/27 Re: [PR] Feature/grade [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/27 Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] via GitHub
• 2026/02/27 Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
• 2026/02/27 Re: [PR] MINOR: Made shutdown request more robust. [kafka] via GitHub
• 2026/02/27 Re: [PR] MINOR: version update: 4.1.1 -->> 4.2.0 [kafka] via GitHub
• 2026/02/27 Re: [PR] MINOR: Add 4.2.0 to system tests [kafka] via GitHub
• 2026/02/27 [jira] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers Nishant Kumar (Jira)
• 2026/02/27 [jira] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders Nishant Kumar (Jira)
• 2026/02/27 [jira] [Assigned] (KAFKA-8504) Update Docs to explain how to use suppress() in more details Matthias J. Sax (Jira)
• 2026/02/27 [jira] [Resolved] (KAFKA-8416) Improve Documentation for Enabling Optimizations Matthias J. Sax (Jira)
• 2026/02/27 [jira] [Resolved] (KAFKA-8504) Update Docs to explain how to use suppress() in more details Matthias J. Sax (Jira)
• 2026/02/27 [jira] [Comment Edited] (KAFKA-13819) Add application.server to Streams assignor logs when set Kartikay Dubey (Jira)
• 2026/02/27 [jira] [Commented] (KAFKA-13819) Add application.server to Streams assignor logs when set Kartikay Dubey (Jira)
• 2026/02/27 [jira] [Assigned] (KAFKA-13819) Add application.server to Streams assignor logs when set Kartikay Dubey (Jira)
• 2026/02/27 [jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls Kirk True (Jira)
• 2026/02/27 [jira] [Commented] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Ilyas Toumlilt (Jira)
• 2026/02/27 [jira] [Updated] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Ilyas Toumlilt (Jira)
• 2026/02/27 [jira] [Assigned] (KAFKA-20075) Side effects of 'preferred leader election' schedule change Jonah Hooper (Jira)
• 2026/02/27 [jira] [Commented] (KAFKA-20075) Side effects of 'preferred leader election' schedule change Jonah Hooper (Jira)
• 2026/02/27 [jira] [Updated] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate() Kirk True (Jira)
• 2026/02/27 [jira] [Commented] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller Jira
• 2026/02/27 [jira] [Updated] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller Jira
• 2026/02/27 [jira] [Resolved] (KAFKA-20013) Convert docs to Markdown David Arthur (Jira)
• 2026/02/27 [jira] [Commented] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics Jira
• 2026/02/27 [jira] [Resolved] (KAFKA-20229) Batch offset translation in RemoteClusterUtils Mickael Maison (Jira)
• 2026/02/27 [jira] [Updated] (KAFKA-20228) Do not allow add-controller to send localhost as endpoint Kevin Wu (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls Kirk True (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20053) Implement MockFixedKeyProcessorContext Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-20053) Implement MockFixedKeyProcessorContext Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20053) Implement MockFixedKeyProcessorContext Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Comment Edited] (KAFKA-20053) Implement MockFixedKeyProcessorContext Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-18866) JDK23: UnsupportedOperationException: getSubject is supported only if a security manager is allowed Christian Habermehl (Jira)
• 2026/02/26 [jira] [Commented] (KAFKA-20053) Implement MockFixedKeyProcessorContext Uladzislau Blok (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-18866) JDK23: UnsupportedOperationException: getSubject is supported only if a security manager is allowed Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-4875) Kafka Streams: topic groups and builder.stream API Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-10686) Pluggable standby tasks assignor for Kafka Streams Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-9828) Add partition to TestRecord in streams test-utils Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-8189) Streams should have an option to require names for stateful components Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-5158) Options for handling exceptions during processing Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Commented] (KAFKA-20053) Implement MockFixedKeyProcessorContext Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-8382) Add TimestampedSessionStore Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-20233) Add Broker + Controller Registrations to SamplingRequestLogFilter ADMIN_APIS Kevin Wu (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20233) Add Broker + Controller Registrations to SamplingRequestLogFilter ADMIN_APIS Kevin Wu (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Matthias J. Sax (Jira)
• 2026/02/26 [jira] [Commented] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate() Brian Sang (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate() Brian Sang (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-17865) Protocol documentation field names are sometimes ambiguous Andrew Schofield (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-19962) Fix flaky ShareConsumerTest#testSubscribeOnInvalidTopicThrowsInvalidTopicException Andrew Schofield (Jira)
• 2026/02/26 [jira] [Resolved] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped Andrew Schofield (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20228) Do not allow add-controller to send localhost as endpoint Kevin Wu (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) globaltable processor Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) globaltable processor Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20231) KIP-1290: Rack-Aware Minimum In-Sync Replicas Karl Sorensen (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) globaltable processor Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20230) globaltable processor Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20230) globaltable processor Brandon Wittwer (Jira)
• 2026/02/26 [jira] [Commented] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types Guang Zhao (Jira)
• 2026/02/26 [jira] [Assigned] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types Guang Zhao (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20228) Add-controller can write leader's endpoint to log when promoting observer Kevin Wu (Jira)
• 2026/02/26 [jira] [Updated] (KAFKA-20228) Add-controller can write leader's endpoint to log when promoting observer Kevin Wu (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20229) Batch offset translation in RemoteClusterUtils Mickael Maison (Jira)
• 2026/02/26 [jira] [Comment Edited] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions fujian (Jira)
• 2026/02/26 [jira] [Created] (KAFKA-20228) Leader should use observer's reported listener when adding voter Kevin Wu (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-18800) Deprecate Authorizer#aclCount Ming-Yen Chung (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions fujian (Jira)
• 2026/02/25 [jira] [Comment Edited] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions fujian (Jira)
• 2026/02/25 [jira] [Resolved] (KAFKA-20153) Upgrade ducktape from 0.12 to 0.13 Chia-Ping Tsai (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-17789) State updater stuck when starting with empty state folder Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-20056) Allow to Store Record Headers in State Stores Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-10725) Merge StoreQueryIntegrationTest and QueryableStateIntegrationTest Matthias J. Sax (Jira)
• 2026/02/25 [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (3/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka] via GitHub
• 2026/02/25 [jira] [Assigned] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events Kevin Wu (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events Kevin Wu (Jira)
• 2026/02/25 Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
• 2026/02/25 [jira] [Commented] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events TaiJuWu (Jira)
• 2026/02/25 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/25 [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-8504: Add warning about grace period required for suppress() with untilWindowCloses [kafka] via GitHub
• 2026/02/25 [jira] [Assigned] (KAFKA-8504) Update Docs to explain how to use suppress() in more details Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-8416) Improve Documentation for Enabling Optimizations Matthias J. Sax (Jira)
• 2026/02/25 Re: [PR] MINOR: remove unnecessary empty statement in ProcessingExceptionHandler [kafka] via GitHub
• 2026/02/25 Re: [PR] MINOR: version update: 4.1.1 -->> 4.2.0 [kafka] via GitHub
• 2026/02/25 Re: [PR] MINOR: Update KafkaStreams.start JavaDocs [kafka] via GitHub
• 2026/02/25 Re: [PR] MINOR: refactor Kafka Streams "segment" code [kafka] via GitHub
• 2026/02/25 [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-14412: Use shared cache for Task offset sums [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-14412: Use shared cache for Task offset sums [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka] via GitHub
• 2026/02/25 [jira] [Updated] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL Matthias J. Sax (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL Matthias J. Sax (Jira)
• 2026/02/25 Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20212: Manage offsets in RocksDBStore [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20212: Manage offsets in RocksDBStore [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20212: Manage offsets in RocksDBStore [kafka] via GitHub
• 2026/02/25 [jira] [Assigned] (KAFKA-20225) Introduce event scheduler framework in KRaft Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20225) Introduce event scheduler framework in KRaft Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20227) Move KRaft RPC handling to event executors Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-19830) Refactor KafkaRaftClient to use event scheduler framework Kevin Wu (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20226) Add KRaft layer benchmarks Kevin Wu (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20226) Add KRaft layer benchmarks Kevin Wu (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20227) Move RPC handling to event executors Kevin Wu (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20225) Introduce event scheduler framework in KRaft Kevin Wu (Jira)
• 2026/02/25 Re: [PR] KAFKA-20212: Manage offsets in RocksDBStore [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (5/N) [kafka] via GitHub
• 2026/02/25 [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types TengYao Chi (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-20155) Implement lazy deserialization mechanism TengYao Chi (Jira)
• 2026/02/25 [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka] via GitHub
• 2026/02/25 [PR] 20212 Manage offsets in RocksDBStore [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka] via GitHub
• 2026/02/25 [jira] [Commented] (KAFKA-20217) Convert KafkaConfig from Scala to Java Mahsa Seifikar (Jira)
• 2026/02/25 [PR] KAFKA-19562: Replace hand-written AbortedTxn with generated protocol [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-19149: Add KIP-877 support to MirrorMaker [kafka] via GitHub
• 2026/02/25 [PR] KAFKA-19149: Add KIP-877 support to MirrorMaker [kafka] via GitHub
• 2026/02/25 [jira] [Created] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication TengYao Chi (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups sanghyeok An (Jira)
• 2026/02/25 [jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group sanghyeok An (Jira)
• 2026/02/25 [jira] [Updated] (KAFKA-20223) Extended I/O Metrics Collection Sahil Devgon (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20223) Extended I/O Metrics Collection Sahil Devgon (Jira)
• 2026/02/25 Re: [PR] KAFKA-20158: Add ChangeLoggingSessionBytesStoreWithHeaders for header-aware session changelog logging (3/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20158: Add ChangeLoggingSessionBytesStoreWithHeaders for header-aware session changelog logging (3/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/25 [jira] [Commented] (KAFKA-20164) Add Kraft layer support for snapshots with metadata records via new handleLoadBootstrap John Mannooparambil (Jira)
• 2026/02/25 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka] via GitHub
• 2026/02/25 [PR] KAFKA-20178 Move LogCleanerIntegrationTest from core to storage [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka] via GitHub
• 2026/02/25 Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
• 2026/02/25 Re: [PR] KAFKA-20168: Downgrade Jetty from 12.0.32 to 12.0.25 to fix SLF4J 2.x incompatibility (4.1) [kafka] via GitHub
• 2026/02/25 [jira] [Assigned] (KAFKA-15853) Move KafkaConfig to server module Uladzislau Blok (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-15853) Move KafkaConfig to server module Uladzislau Blok (Jira)
• 2026/02/25 Re: [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] via GitHub
• 2026/02/25 [jira] [Commented] (KAFKA-20217) Convert KafkaConfig from Scala to Java Uladzislau Blok (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL Alieh Saeedi (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL Alieh Saeedi (Jira)
• 2026/02/25 [jira] [Assigned] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL Alieh Saeedi (Jira)
• 2026/02/25 [jira] [Created] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL Alieh Saeedi (Jira)
• 2026/02/25 Re: [PR] MINOR: remove unnecessary empty statement in ProcessingExceptionHandler [kafka] via GitHub

• Earlier messages
• Later messages