You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode - posted by "M Paget (Jira)" <ji...@apache.org> on 2026/03/01 00:53:00 UTC, 0 replies.
- Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/01 02:19:39 UTC, 2 replies.
- Re: [PR] MINOR: Clean up checkstyle configuration [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:56:13 UTC, 1 replies.
- Re: [PR] KAFKA-19939 Extending ProcessExceptionalHandler for Global Thread [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:56:15 UTC, 21 replies.
- Re: [PR] MINOR: Add startup-duration logging to help with Kafka startup performance tuning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:56:48 UTC, 0 replies.
- Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:57:17 UTC, 2 replies.
- Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:57:20 UTC, 0 replies.
- Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 03:57:32 UTC, 0 replies.
- Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/01 04:34:52 UTC, 4 replies.
- Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/01 04:40:52 UTC, 16 replies.
- Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Server Side. [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/01 04:50:42 UTC, 12 replies.
- Re: [PR] KAFKA-19943: Implement state store clean up on start [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/01 11:25:17 UTC, 12 replies.
- [jira] [Commented] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/03/01 13:15:00 UTC, 3 replies.
- [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/03/01 13:59:27 UTC, 13 replies.
- Re: [PR] KAFKA-20083: Move BrokerLifecycleManager to server module [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/03/01 14:02:22 UTC, 0 replies.
- [PR] refactor: simplify code [kafka] - posted by "spotlesscoder (via GitHub)" <gi...@apache.org> on 2026/03/01 14:25:43 UTC, 1 replies.
- Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/01 16:27:23 UTC, 26 replies.
- Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/03/01 16:40:03 UTC, 35 replies.
- Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/01 17:12:05 UTC, 10 replies.
- [jira] [Updated] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/01 18:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/01 18:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group - posted by "Jhen-Yung Hsu (Jira)" <ji...@apache.org> on 2026/03/01 18:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group - posted by "Jhen-Yung Hsu (Jira)" <ji...@apache.org> on 2026/03/01 18:24:00 UTC, 8 replies.
- Re: [PR] KAFKA-20204: Remove partition-level `ExpiresPerSec` metrics when the broker no longer owns the partition [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/01 18:56:43 UTC, 3 replies.
- [PR] handling 0 partitions [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/01 21:07:52 UTC, 3 replies.
- [jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/01 21:13:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-9651) Divide by zero in DefaultPartitioner - posted by "Tom Bentley (Jira)" <ji...@apache.org> on 2026/03/01 21:41:00 UTC, 1 replies.
- Re: [PR] Update Quickstart link to point to GitHub [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:51:47 UTC, 0 replies.
- Re: [PR] KAFKA-14615: Use sizeCompare for collection size equality checks [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:51:49 UTC, 0 replies.
- Re: [PR] MINOR: fix overwrite in recursive parent-node matching [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:51:50 UTC, 0 replies.
- Re: [PR] KAFKA-20193: Remove `static T value(...)` method from ValueTimestampHeadersDeserializer if not needed [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:51:51 UTC, 4 replies.
- Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:51:53 UTC, 7 replies.
- Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:52:04 UTC, 3 replies.
- Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 03:52:18 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19939) ProductionExceptionHandler and DLQ does not support global thread - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2026/03/02 04:02:00 UTC, 0 replies.
- [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/02 04:03:04 UTC, 2 replies.
- [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/02 04:05:03 UTC, 2 replies.
- Re: [PR] Support keystore with multiple alias entries [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 04:16:36 UTC, 0 replies.
- Re: [PR] KAFKA-17178: Internal KTable#transformValues refactoring [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 04:16:39 UTC, 0 replies.
- Re: [PR] KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 04:16:43 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller - posted by "Sven Dewit (Jira)" <ji...@apache.org> on 2026/03/02 06:00:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller - posted by "Sven Dewit (Jira)" <ji...@apache.org> on 2026/03/02 06:00:00 UTC, 0 replies.
- [PR] KAFKA-20157 Add RetentionSizeInPercent metrics for regular topics [kafka] - posted by "manangupta111 (via GitHub)" <gi...@apache.org> on 2026/03/02 06:05:04 UTC, 3 replies.
- [PR] KAFKA-20157 documment KIP-1257 partition size percentage metrics [kafka] - posted by "manangupta111 (via GitHub)" <gi...@apache.org> on 2026/03/02 06:11:19 UTC, 0 replies.
- Re: [PR] KAFKA-19144 Move DelayedProduce to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/02 06:46:34 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20204) Remove partition-level `ExpiresPerSec`metrics when the broker no longer ownsthe partition - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/02 06:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "Yin Lei (Jira)" <ji...@apache.org> on 2026/03/02 08:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "Yin Lei (Jira)" <ji...@apache.org> on 2026/03/02 08:14:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics - posted by "Prince Raiyani (Jira)" <ji...@apache.org> on 2026/03/02 08:17:00 UTC, 2 replies.
- Re: [PR] KAFKA-19709: Add LegacyCheckpointingStateStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/02 08:46:06 UTC, 10 replies.
- [jira] [Created] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode - posted by "mapan (Jira)" <ji...@apache.org> on 2026/03/02 09:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode - posted by "mapan (Jira)" <ji...@apache.org> on 2026/03/02 09:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/02 09:21:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-20239) Document Kafka ACLs required for Connect workers - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/03/02 09:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/02 09:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/02 10:07:00 UTC, 3 replies.
- Re: [PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka] - posted by "lfritz-seweurodrive (via GitHub)" <gi...@apache.org> on 2026/03/02 11:44:20 UTC, 1 replies.
- [PR] MINOR: Update jackson due to CVE [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2026/03/02 11:58:38 UTC, 3 replies.
- [jira] [Created] (KAFKA-20240) Update upgrade.md to mention new configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/02 13:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/02 13:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20242) Release notes links are broken in documentation - posted by "Anton Agestam (Jira)" <ji...@apache.org> on 2026/03/02 14:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20242) Release notes links are broken in documentation - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2026/03/02 14:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20239) Document Kafka ACLs required for Connect workers - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/02 14:40:00 UTC, 0 replies.
- Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka] - posted by "mfvitale (via GitHub)" <gi...@apache.org> on 2026/03/02 14:45:37 UTC, 17 replies.
- Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/02 14:56:58 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2026/03/02 15:00:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2026/03/02 15:00:00 UTC, 1 replies.
- Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/02 15:07:11 UTC, 13 replies.
- Re: [PR] KAFKA-20157 Document KIP-1257 partition size percentage metrics [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2026/03/02 15:28:14 UTC, 1 replies.
- Re: [PR] MINOR: Update jackson to 2.20.1 and jackson-annotations to 2.20 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/02 15:32:51 UTC, 2 replies.
- [jira] [Created] (KAFKA-20243) TCP connection count per client.id - posted by "Nebojsa Simic (Jira)" <ji...@apache.org> on 2026/03/02 15:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring - posted by "Manan Gupta (Jira)" <ji...@apache.org> on 2026/03/02 16:14:00 UTC, 0 replies.
- Re: [PR] KAFKA-20212: Manage offsets in RocksDBStore [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2026/03/02 16:30:14 UTC, 26 replies.
- [jira] [Created] (KAFKA-20244) Kafka 5.0.0 updates for KIP-1280 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/02 16:33:00 UTC, 0 replies.
- Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/02 17:00:24 UTC, 23 replies.
- [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] - posted by "dalelane (via GitHub)" <gi...@apache.org> on 2026/03/02 17:09:35 UTC, 8 replies.
- Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/02 17:24:04 UTC, 0 replies.
- Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (3/N) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/02 17:38:15 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20242) Release notes links are broken in documentation - posted by "Karl Sorensen (Jira)" <ji...@apache.org> on 2026/03/02 17:47:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20242) Release notes links are broken in documentation - posted by "Karl Sorensen (Jira)" <ji...@apache.org> on 2026/03/02 17:47:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix typo 'overidden' to 'overridden' in produce_consume_validate.py [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/02 17:50:50 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20162) Validation and enforcement of group configurations - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/02 18:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20160) Group configuration for share.partition.max.record.locks - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/02 18:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20245) Implementation for dead-letter queues for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/02 18:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/03/02 19:32:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/03/02 20:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/02 20:25:40 UTC, 20 replies.
- Re: [PR] KAFKA-19541 Add new KIP-1219 quorum configurations [kafka] - posted by "josefk31 (via GitHub)" <gi...@apache.org> on 2026/03/02 21:28:59 UTC, 44 replies.
- [jira] [Assigned] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/02 21:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/02 21:55:56 UTC, 5 replies.
- [jira] [Created] (KAFKA-20246) Detection and handling of misrouted connections - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/02 22:03:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/02 22:40:51 UTC, 4 replies.
- Re: [PR] MINOR: Improve CRC failure handling share groups [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/02 22:52:19 UTC, 0 replies.
- Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/03/03 00:28:53 UTC, 19 replies.
- Re: [PR] MINOR: Optimize Struct.validate() field iteration [kafka] - posted by "yuzawa-san (via GitHub)" <gi...@apache.org> on 2026/03/03 01:37:57 UTC, 0 replies.
- Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/03 01:44:33 UTC, 5 replies.
- [jira] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "Yin Lei (Jira)" <ji...@apache.org> on 2026/03/03 02:36:00 UTC, 0 replies.
- Re: [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 03:51:37 UTC, 1 replies.
- Re: [PR] Add MetaProperties V2 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 03:51:40 UTC, 1 replies.
- Re: [PR] KAFKA-19891: Suppress error-level heartbeat logs during consumer close [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 04:16:33 UTC, 0 replies.
- Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 04:16:35 UTC, 2 replies.
- [PR] KAFKA-20211: Add group coordinator background metrics [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/03 04:32:33 UTC, 3 replies.
- [PR] KAFKA-17895: Add num-keys metric for in-memory state stores [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/03/03 04:51:27 UTC, 7 replies.
- [jira] [Commented] (KAFKA-20243) TCP connection count per client.id - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/03/03 05:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20243) TCP connection count per client.id - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/03/03 05:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20210) Add group.coordinator.executor.threads config - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/03 06:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (5/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/03 07:39:47 UTC, 0 replies.
- Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/03 07:46:39 UTC, 13 replies.
- [jira] [Commented] (KAFKA-20078) kafka-dump-log tool should return proper exit code - posted by "Chih-Yuan Chien (Jira)" <ji...@apache.org> on 2026/03/03 07:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20078) kafka-dump-log tool should return proper exit code - posted by "Chih-Yuan Chien (Jira)" <ji...@apache.org> on 2026/03/03 08:00:00 UTC, 0 replies.
- [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka] - posted by "praiyani6789 (via GitHub)" <gi...@apache.org> on 2026/03/03 08:38:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-20247) ControllerRegistrationManager does not retry registration after timing out - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/03 08:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-19562: Replace hand-written AbortedTxn with generated protocol [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/03 09:13:35 UTC, 14 replies.
- [jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/03 09:39:00 UTC, 13 replies.
- Re: [PR] KAFKA-19446: Add Transaction Version to request builder [2/3] [kafka] - posted by "firecow (via GitHub)" <gi...@apache.org> on 2026/03/03 10:48:36 UTC, 0 replies.
- Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2026/03/03 10:50:20 UTC, 17 replies.
- [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/03/03 11:00:53 UTC, 14 replies.
- Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/03/03 11:12:34 UTC, 6 replies.
- [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/03 11:18:00 UTC, 4 replies.
- Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/03 12:09:16 UTC, 1 replies.
- Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/03 12:19:20 UTC, 2 replies.
- [jira] [Created] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/03 12:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/03 12:32:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-20249) Optimize rawValue methods across all Deserializers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/03 12:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/03 12:55:00 UTC, 8 replies.
- Re: [PR] KAFKA-20178 Move LogCleanerIntegrationTest from core to storage [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/03 13:05:49 UTC, 7 replies.
- [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/03 13:20:17 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Adapters - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/03 13:46:00 UTC, 0 replies.
- [PR] KAFKA-20241 [kafka] - posted by "averemee-si (via GitHub)" <gi...@apache.org> on 2026/03/03 14:26:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-20250) Move UnifiedLogTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/03 14:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/03 14:42:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20250) Move UnifiedLogTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/03 14:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/03 14:50:33 UTC, 4 replies.
- [PR] Kafka 20241 fix [kafka] - posted by "averemee-si (via GitHub)" <gi...@apache.org> on 2026/03/03 15:26:54 UTC, 0 replies.
- Re: [PR] KAFKA-19939 Extend ProcessingExceptionalHandler for Global Thread [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/03 15:48:16 UTC, 3 replies.
- Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2026/03/03 16:09:57 UTC, 34 replies.
- [jira] [Resolved] (KAFKA-20211) Add new group coordinator executor metrics - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/03 17:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/03 18:06:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/03 21:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/03 21:51:00 UTC, 0 replies.
- [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/03 22:11:03 UTC, 3 replies.
- Re: [PR] MINOR: Keep pendingTask as WakeupFuture if currentTask is completed already. [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/03 23:38:23 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-19655) The normal topic auto-creation paths should use num.partitions and default.replication.factor from the controller properties - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/03/03 23:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/04 00:33:07 UTC, 13 replies.
- [PR] fix: replace printStackTrace() with proper logging in KafkaStreamsNamedTopologyWrapper [kafka] - posted by "Senrian (via GitHub)" <gi...@apache.org> on 2026/03/04 01:43:41 UTC, 1 replies.
- Re: [PR] kAFKA-9651:handling 0 partitions [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/04 02:08:36 UTC, 1 replies.
- Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/03/04 02:55:57 UTC, 17 replies.
- [PR] KAFKA-20205: Refactor serialization and deserialization code for *WithHeaders types [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/03/04 03:16:59 UTC, 5 replies.
- Re: [PR] MINOR: Move KRaftMetadataCachePublisher to metadata module and convert to Java [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 03:50:05 UTC, 0 replies.
- Re: [PR] KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 03:50:07 UTC, 3 replies.
- Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 04:14:23 UTC, 1 replies.
- Re: [PR] Update README.md [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 04:14:26 UTC, 1 replies.
- Re: [PR] KAFKA-19921 : Test-Common | Fixed order of arguments of assertEquals in unit tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 04:14:36 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/04 05:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/04 05:21:00 UTC, 2 replies.
- Re: [PR] MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/04 06:28:49 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode - posted by "Karl Sorensen (Jira)" <ji...@apache.org> on 2026/03/04 09:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20251) Add assignment batching and offload configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/04 10:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/04 10:44:00 UTC, 0 replies.
- [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/04 12:44:24 UTC, 33 replies.
- [jira] [Assigned] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils - posted by "Kartikay Dubey (Jira)" <ji...@apache.org> on 2026/03/04 13:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils - posted by "Kartikay Dubey (Jira)" <ji...@apache.org> on 2026/03/04 13:02:00 UTC, 2 replies.
- Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/04 13:11:12 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/04 13:48:00 UTC, 0 replies.
- [PR] MINOR: fix protocol link in templates.py [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/04 13:52:27 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/04 14:03:00 UTC, 0 replies.
- [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/03/04 14:25:57 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/04 14:29:00 UTC, 0 replies.
- Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/04 14:58:10 UTC, 3 replies.
- [PR] MINOR: make processMessages task outputs relocatable for build cache [kafka] - posted by "ribafish (via GitHub)" <gi...@apache.org> on 2026/03/04 15:20:32 UTC, 1 replies.
- Re: [PR] MINOR: Fix off-by-one in ShareCoordinatorShard snapshot update count [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/04 15:29:25 UTC, 0 replies.
- [PR] MINOR: Ignore unassigned records in MockConsumer [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/04 15:41:10 UTC, 3 replies.
- [PR] KAFKA-20207: handle the ClusterIdRecord as part of the metadata image [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/03/04 16:41:11 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20158) Implement SessionStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/04 16:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/04 17:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/04 17:40:00 UTC, 0 replies.
- [PR] KAFKA-20162: Validation and enforcement of group configurations [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/04 18:14:20 UTC, 16 replies.
- [jira] [Created] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Marko Štrukelj (Jira)" <ji...@apache.org> on 2026/03/04 18:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Marko Štrukelj (Jira)" <ji...@apache.org> on 2026/03/04 18:25:00 UTC, 1 replies.
- [PR] Rlm [kafka] - posted by "TinaTong-coder (via GitHub)" <gi...@apache.org> on 2026/03/04 19:34:54 UTC, 0 replies.
- [PR] MINOR: version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/04 19:46:09 UTC, 1 replies.
- [jira] [Created] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/04 19:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/04 20:13:00 UTC, 2 replies.
- Re: [PR] KAFKA-20090: rotate producerId when epoch exhausted during transaction completion. [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2026/03/05 01:14:06 UTC, 4 replies.
- [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/05 03:36:27 UTC, 5 replies.
- Re: [PR] fix: replace 12 bare except clauses with except Exception [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 03:51:12 UTC, 0 replies.
- Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams (WIP) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 03:51:14 UTC, 0 replies.
- Re: [PR] KAFKA-19830 [1/N]: refactor KafkaRaftClient to use event-based scheduling [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 03:51:17 UTC, 1 replies.
- Re: [PR] Update EndToEndLatency.java [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 04:15:52 UTC, 1 replies.
- Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/05 04:39:30 UTC, 19 replies.
- [PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/03/05 04:59:58 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/03/05 06:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate - posted by "Yu Xiao (Jira)" <ji...@apache.org> on 2026/03/05 08:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20132) Implement TimestampedKeyValueStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 08:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 08:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20256) DLQManager interace and default impl - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/03/05 09:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20245) Implementation for dead-letter queues for share groups in Share Partition - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/03/05 09:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/03/05 09:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:41:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:42:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20261) Upgrade path for plain window store to headers store - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20260) Upgrade path from plain KV store to headers store - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 09:46:00 UTC, 0 replies.
- [PR] KAFKA-20254: Add upgrade guide warning about classic to streams group migration in 4.2.0 [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/05 09:55:11 UTC, 3 replies.
- [jira] [Created] (KAFKA-20262) Changelog tombstone records drop custom headers when using headers-aware state stores - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/05 09:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 10:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 10:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 10:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/05 10:20:00 UTC, 0 replies.
- [PR] KAFKA-20262: Changelog tombstone records drop custom headers when usi… [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/05 10:20:58 UTC, 9 replies.
- [PR] KAFKA-20256: Add ShareGroupDLQ interface and some infra classes. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/03/05 10:26:32 UTC, 3 replies.
- [PR] KAFKA-20254: Fix streams group creation failing when simple classic group exists [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/05 10:31:41 UTC, 2 replies.
- [jira] [Updated] (KAFKA-19752) Move UnifiedLogTest to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/05 11:42:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation - posted by "appchemist (Jira)" <ji...@apache.org> on 2026/03/05 13:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation - posted by "appchemist (Jira)" <ji...@apache.org> on 2026/03/05 13:14:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20178) Move LogCleanerIntegrationTest to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/05 14:05:00 UTC, 0 replies.
- Re: [PR] MINOR: Replace Properties with Map in ControllerConfigurationValidator validation path [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/05 14:05:33 UTC, 12 replies.
- [PR] MINOR: Add 4.2.0 to system tests [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/03/05 14:05:53 UTC, 2 replies.
- [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/05 14:19:27 UTC, 13 replies.
- [jira] [Created] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/03/05 14:23:00 UTC, 0 replies.
- [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/05 15:33:11 UTC, 14 replies.
- [jira] [Commented] (KAFKA-19752) Move UnifiedLogTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/05 15:57:00 UTC, 3 replies.
- [PR] KAFKA-7952: Switch stream from RocksDB to in-memory [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/03/05 16:01:14 UTC, 4 replies.
- [PR] KAFKA-7952: Switch KTableAggregateTest from RocksDB to in-memory storage [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/03/05 16:10:43 UTC, 1 replies.
- [PR] KAFKA-20035 Prevent data loss during partition expansion for dynamically added partitions [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/05 16:12:12 UTC, 1 replies.
- Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/03/05 16:12:29 UTC, 8 replies.
- [PR] KAFKA-20257: Refactor GlobalStateManagerImpl [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/05 16:24:58 UTC, 3 replies.
- Re: [PR] KAFKA-7952: Switch stream store from RocksDB to in-memory [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/03/05 16:25:09 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 16:34:00 UTC, 0 replies.
- [PR] KAFKA-20202: Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/05 16:56:16 UTC, 13 replies.
- Re: [PR] KAFKA-20066: Assignment epochs for consumer groups [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/03/05 17:13:39 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/05 17:26:00 UTC, 0 replies.
- [PR] MINOR: version updates for build and test dependencies [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/05 18:00:44 UTC, 11 replies.
- Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, examples, and jmh-benchmarks [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/05 18:36:47 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions - posted by "S. Sikka (Jira)" <ji...@apache.org> on 2026/03/05 20:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20256) DLQManager interace and default impl - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20260) Upgrade path from plain KV store to headers store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20261) Upgrade path for plain window store to headers store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20262) Changelog tombstone records drop custom headers when using headers-aware state stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/05 20:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20240) Update upgrade.md to mention new configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/05 21:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20251) Add assignment batching and offload configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/05 21:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20266) Record assignment timestamps - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/05 21:07:00 UTC, 0 replies.
- [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/05 21:23:08 UTC, 26 replies.
- [PR] KAFKA-19418: Fix for flaky verifiable producer system test (#20001) [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/05 23:49:14 UTC, 1 replies.
- [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] - posted by "Hongten (via GitHub)" <gi...@apache.org> on 2026/03/06 03:33:30 UTC, 28 replies.
- Re: [PR] KAFKA-13392 Resolve Timeout Exception triggering reassign partitions with --bootstrap-server option [kafka] - posted by "Hongten (via GitHub)" <gi...@apache.org> on 2026/03/06 03:35:11 UTC, 1 replies.
- Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (5/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 03:50:16 UTC, 0 replies.
- Re: [PR] KAFKA-20232: Fix WakeupException in awaitMetadataUpdate() [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 03:50:18 UTC, 0 replies.
- Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (4/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 03:50:19 UTC, 0 replies.
- Re: [PR] Add test scale up controller with "initial controllers" formatting [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 03:50:26 UTC, 2 replies.
- [PR] MINOR: Set unequal assignment epochs fallback to default epoch for streams group [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/03/06 05:41:19 UTC, 4 replies.
- [jira] [Commented] (KAFKA-13392) Timeout Exception triggering reassign partitions with --bootstrap-server option - posted by "hongten (Jira)" <ji...@apache.org> on 2026/03/06 06:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20267) Move LogCleanerParameterizedIntegrationTest to storage module - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/06 08:41:00 UTC, 0 replies.
- [PR] KIP-646: Serializer API should support ByteBuffer [kafka] - posted by "flore77 (via GitHub)" <gi...@apache.org> on 2026/03/06 09:51:50 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20243) TCP connection count per client.id - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/03/06 09:53:00 UTC, 0 replies.
- [PR] KAFKA-20267 Move LogCleanerParameterizedIntegrationTest to storage module [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/06 10:14:31 UTC, 15 replies.
- [PR] MINOR: Update testAsyncConsumerWithConsumerProtocolDisabled to use group.version [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/06 12:23:49 UTC, 1 replies.
- [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in storage and metadata [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/06 12:58:34 UTC, 5 replies.
- Re: [PR] Add ZSTD compression configuration options [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/06 13:00:49 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20231) KIP-1290: Rack-Aware Minimum In-Sync Replicas - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/06 13:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20116) Support HA assignor in the streams rebalance protocol - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/06 13:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/06 14:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-5761: Serializer API should support ByteBuffer [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/03/06 14:16:49 UTC, 2 replies.
- [jira] [Created] (KAFKA-20268) Start group epochs at 2 - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/06 14:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20269) Refactor GroupMetadataManager assignment updates - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/06 14:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20270) jetty-server vulnerability CVE-2026-1605 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/06 15:53:00 UTC, 0 replies.
- [PR] KAFKA-20270 [kafka] - posted by "averemee-si (via GitHub)" <gi...@apache.org> on 2026/03/06 16:04:27 UTC, 5 replies.
- [PR] MINOR: refactor warning message [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/03/06 16:04:33 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20270) jetty-server vulnerability CVE-2026-1605 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/06 16:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-17120) Race condition in KafkaStreams.close can result in StreamsException "Failed to shut down while in state" - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/06 17:29:00 UTC, 0 replies.
- Re: [PR] KAFKA-20092 buildscript and project dependencies version updates [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/06 17:40:55 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/06 17:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/06 17:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/06 17:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20134) Implement TimestampedWindowStoreWithHeaders - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/06 18:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry - posted by "Emmanuel Oppong (Jira)" <ji...@apache.org> on 2026/03/06 18:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20270) jetty-server vulnerability CVE-2026-1605 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/06 20:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20173: Propagate headers into serde 2/N [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/06 21:12:44 UTC, 9 replies.
- [jira] [Updated] (KAFKA-20270) jetty-server vulnerability CVE-2026-1605 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/06 21:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-19697: Fix unregistering connectorStatusMetrics NPE if tasks fa… [kafka] - posted by "pdavidson100 (via GitHub)" <gi...@apache.org> on 2026/03/06 21:59:56 UTC, 10 replies.
- [jira] [Commented] (KAFKA-20219) Override `getPosition` correctly for TimestampedKeyValueStoreWithHeaders - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/06 23:54:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20271) Initialize assignment epoch to -1 when there is no assignment yet - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20272) Rebalance classic members only on new assignment - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20266) Record assignment timestamps - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:37:00 UTC, 0 replies.
- Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 03:44:38 UTC, 3 replies.
- [jira] [Created] (KAFKA-20273) Trigger rebalance on downgrade to classic group with outdated assignment - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20273) Trigger rebalance on downgrade to classic group when assignment is outdated - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20273) Trigger rebalance on downgrade to classic group when assignment is stale - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/07 03:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 04:07:57 UTC, 1 replies.
- Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 04:08:00 UTC, 1 replies.
- Re: [PR] Implementing KIP-977 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 04:08:03 UTC, 1 replies.
- Re: [PR] KAFKA-19858: Move the __remote_log_metadata to internal [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 04:08:08 UTC, 1 replies.
- [jira] [Created] (KAFKA-20274) GitHub Actions job "Docker Image CVE Scanner" fails - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/07 04:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20274) GitHub Actions job "Docker Image CVE Scanner" fails - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/07 04:33:00 UTC, 1 replies.
- [PR] KAFKA-20272 [1/N]: Rebalance classic members only on new assignment [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/07 05:07:33 UTC, 0 replies.
- [PR] KAFKA-20273 [1/N]: Rebalance on classic group downgrade with stale assignment [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/07 05:08:54 UTC, 0 replies.
- [PR] KAFKA-20269: Refactor target assignment update for delayed assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/07 05:10:11 UTC, 7 replies.
- [jira] [Created] (KAFKA-20275) API to set commit offsets without being subscribed - posted by "Werner Daehn (Jira)" <ji...@apache.org> on 2026/03/07 08:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20276) API to read data between offsets - posted by "Werner Daehn (Jira)" <ji...@apache.org> on 2026/03/07 08:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20274) GitHub Actions job "Docker Image CVE Scanner" fails - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/07 09:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20266) Record assignment timestamps - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/07 11:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/07 12:03:00 UTC, 0 replies.
- [PR] KAFKA-13630: Reduce deque lock scope in RecordAccumulator.drainBatchesForOneNode [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/07 16:54:43 UTC, 8 replies.
- Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka] - posted by "jack2012aa (via GitHub)" <gi...@apache.org> on 2026/03/07 17:16:45 UTC, 1 replies.
- [jira] [Created] (KAFKA-20277) Verify existing IQv2 methods for SessionStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/07 17:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/07 19:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/07 19:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20260) Upgrade path from plain KV store to headers store - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/07 19:09:00 UTC, 0 replies.
- [PR] KAFKA-20260: Upgrade path from plain KV store to headers store [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/07 19:14:28 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-20218) Add downgrade tests in TimestampedKeyValueStoreWithHeadersTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/07 19:54:00 UTC, 0 replies.
- [PR] KAFKA-20218: Add downgrade tests in TimestampedKeyValueStoreWithHeadersTest [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/07 20:04:05 UTC, 2 replies.
- [PR] Fix shouldSign regex to handle nano version hotfix segment [kafka] - posted by "cchristous (via GitHub)" <gi...@apache.org> on 2026/03/07 21:36:11 UTC, 1 replies.
- [jira] [Created] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/07 22:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/07 22:14:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20280) DLQ not supported for ProductionExceptionHander on global thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/08 00:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19939) ProductionExceptionHandler not supported on global thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/08 00:07:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19939) ProductionExceptionHandler not supported on global thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/08 00:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20280) DLQ not supported for ProductionExceptionHander on global thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/08 00:10:00 UTC, 0 replies.
- [PR] KAFKA-20277: Add session store with headers infra and support for IQv2 [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/08 01:16:37 UTC, 0 replies.
- Re: [PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 03:50:31 UTC, 11 replies.
- Re: [PR] KAFKA-20235: Replace System.out.println with proper logger for missing property file warning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 03:50:33 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20280) DLQ not supported for ProductionExceptionHander on global thread - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2026/03/08 04:26:00 UTC, 0 replies.
- [PR] KAFKA-16600: Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/08 05:00:05 UTC, 1 replies.
- [PR] KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/08 06:31:35 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-20077) Producer using transactions v1 could hang on flush upon retriable failures adding partitions to tx - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/08 06:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20077) Producer using transactions v1 could hang on flush upon retriable failures adding partitions to tx - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/08 06:33:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException - posted by "wangqingyu (Jira)" <ji...@apache.org> on 2026/03/08 06:45:00 UTC, 0 replies.
- [PR] docs: Add contributing guidelines documentation [kafka] - posted by "rohansood10 (via GitHub)" <gi...@apache.org> on 2026/03/08 07:16:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19873) Add explicit liveness check for transactional producers - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/08 07:33:00 UTC, 0 replies.
- [PR] MINOR: refactor AbstractSegmentsTests to reduce redundancies [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/08 08:07:37 UTC, 4 replies.
- [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/08 09:50:41 UTC, 1 replies.
- [PR] KAFKA-20179 : Avoid headers deserialization during changelogging [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/08 12:29:49 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20179) Avoiding headers deserialization while changelogging - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/08 12:31:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20281) Enhance docs and test coverage for `producer-props` and `command-property` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/08 12:51:00 UTC, 0 replies.
- [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/08 13:30:50 UTC, 5 replies.
- [jira] [Commented] (KAFKA-19863) Add documentation on how to implement a custom exception handler - posted by "Rajarshi Misra (Jira)" <ji...@apache.org> on 2026/03/08 14:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-14472: Move TransactionIndex and related to storage module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/08 14:21:50 UTC, 0 replies.
- [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/03/08 15:29:23 UTC, 11 replies.
- [PR] Address KAFKA-20252: Migrate clearYammerMetrics to TestUtils [kafka] - posted by "dubeyKartikay (via GitHub)" <gi...@apache.org> on 2026/03/08 16:21:26 UTC, 13 replies.
- [PR] KAFKA-20158: Adding SessionStore with headers adapters and iterator facade [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/08 17:26:40 UTC, 3 replies.
- [PR] KAFKA-20173: Propagate headers into serde 3/N [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/08 18:35:07 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/08 21:59:00 UTC, 0 replies.
- [PR] KAFKA-19939: StreamsConfig should log WARN by default [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/09 00:17:26 UTC, 4 replies.
- [PR] MINOR: improve generic type safety for IQv2 in metered-store layer [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/09 03:11:40 UTC, 3 replies.
- [PR] KAFKA-20173: Metered layer of kv-stores need to pass Headers [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/09 03:45:09 UTC, 2 replies.
- Re: [PR] KAFKA-19010: Added JVM argument to default configuration [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 04:16:47 UTC, 1 replies.
- Re: [PR] KAFKA-19782: improve Authorizer by using (Patricia) trie [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 04:16:52 UTC, 1 replies.
- Re: [PR] KAFKA-19947 Add Unit test coverage for KafkaCSVMetricsReporter [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 04:16:55 UTC, 1 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - protocol and server (1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 04:16:58 UTC, 1 replies.
- Re: [PR] KIP-1028: AK 3.8.0 Docker Official Image Assets [kafka] - posted by "vincentbernat (via GitHub)" <gi...@apache.org> on 2026/03/09 07:24:50 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20025) Missing dynamic SSL reconfiguration support for KafkaRaftClient - posted by "fujian (Jira)" <ji...@apache.org> on 2026/03/09 07:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/03/09 08:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20246) Detection and handling of misrouted connections - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/09 09:47:00 UTC, 0 replies.
- [PR] MINOR: Fix broken documentation links for Streams Rebalance Protocol [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/09 10:04:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/03/09 10:07:00 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/09 10:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20173: Metered layer of KV-stores needs to pass Headers [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/09 10:46:17 UTC, 15 replies.
- [jira] [Created] (KAFKA-20282) Classic consumer log recommendation for next gen Consumer rebalance protocol - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/09 10:58:00 UTC, 0 replies.
- Re: [PR] KAFKA-20273: Rebalance on classic group downgrade with stale assignment [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/09 11:09:32 UTC, 7 replies.
- [jira] [Created] (KAFKA-20283) [CVE-2025-11143] [jetty-http] - posted by "Krishna Chidrawar (Jira)" <ji...@apache.org> on 2026/03/09 11:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()` - posted by "Young Joo Kim (Jira)" <ji...@apache.org> on 2026/03/09 11:30:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()` - posted by "Young Joo Kim (Jira)" <ji...@apache.org> on 2026/03/09 11:31:00 UTC, 1 replies.
- [PR] KAFKA-19752 Move parts of UnifiedLogTest to storage module [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/09 12:11:06 UTC, 12 replies.
- [PR] MINOR: Fix typo 'boostrap' to 'bootstrap' in KafkaRaftClientTest [kafka] - posted by "xxxxxxjun (via GitHub)" <gi...@apache.org> on 2026/03/09 13:14:45 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-19752) Move UnifiedLogTest to storage module - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/03/09 13:24:00 UTC, 0 replies.
- [PR] KAFKA-20281: Enhance helper message for producer-props and command-property [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/09 13:46:02 UTC, 5 replies.
- Re: [PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/09 13:49:22 UTC, 2 replies.
- [jira] [Created] (KAFKA-20284) Migrate or eliminate core TestUtils - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/09 14:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20284) Migrate or eliminate core TestUtils - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/09 14:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20284) Migrate or eliminate core TestUtils - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/03/09 14:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20272: Rebalance classic members only on new assignment [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/09 14:33:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20272) Rebalance classic members only on new assignment - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/09 14:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20285) Mpve UncleanLeaderElectionTest to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/09 14:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20273) Trigger rebalance on downgrade to classic group when assignment is stale - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/09 14:44:00 UTC, 0 replies.
- [PR] KAFKA-15852: Move UncleanLeaderElectionTest to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/09 15:23:45 UTC, 7 replies.
- [jira] [Commented] (KAFKA-20275) API to set commit offsets without being subscribed - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/09 15:49:00 UTC, 2 replies.
- [PR] HOTFIX GroupMetadataManagerTest compile error [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/09 15:57:34 UTC, 4 replies.
- [PR] KAFKA-20273: Fix merge conflict with KAFKA-20066 [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/09 15:59:25 UTC, 0 replies.
- [jira] [Created] (KAFKA-20286) Refactor ControllerRegistrationManager - posted by "Jonah Hooper (Jira)" <ji...@apache.org> on 2026/03/09 16:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20275) API to set commit offsets without being subscribed - posted by "Werner Daehn (Jira)" <ji...@apache.org> on 2026/03/09 16:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20261) Upgrade path for plain window store to headers store - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/09 17:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-20254: Add integration tests for group migration with compaction and broker restart [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/09 17:43:17 UTC, 7 replies.
- [jira] [Created] (KAFKA-20287) Verify (and potentially fix) if all CF handles (and other objects) are closed correctly - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/09 17:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20288) Remove orphaned groups from GroupConfigManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/09 17:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20289) Broker configs with group config names masquerading as static broker config - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/09 18:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [3/N] [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/03/09 18:05:47 UTC, 25 replies.
- [jira] [Updated] (KAFKA-19943) Stale values in State Store after tombstone was compacted - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/09 18:14:00 UTC, 0 replies.
- Re: [PR] KAFKA-20272, KAFKA-20273: Fix merge conflict with KAFKA-20066 [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/09 18:22:55 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20288) Remove orphaned groups from GroupConfigManager - posted by "Chang-Yu Huang (Jira)" <ji...@apache.org> on 2026/03/09 18:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/09 19:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-10731) Add Support for SSL hot reload - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/09 19:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20216) Jetty 12 requires slf4j 2 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/09 19:41:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-19144) Move DelayedProduce to server module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/09 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20290) Add KIP-1240 information to upgrade documentation - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/09 19:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Preethi KCS (Jira)" <ji...@apache.org> on 2026/03/09 20:55:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Preethi KCS (Jira)" <ji...@apache.org> on 2026/03/09 20:55:00 UTC, 3 replies.
- Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/09 23:36:25 UTC, 6 replies.
- Re: [PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/10 00:10:06 UTC, 1 replies.
- Re: [PR] KAFKA-20184: Remove static jose4j references from DefaultJwtValidator [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/10 00:40:14 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20184) jose4j marked as compileOnly in clients module causes ClassNotFoundException at runtime for OAuth authentication - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/10 00:41:00 UTC, 0 replies.
- [PR] MINOR: Migrate NodeToControllerRequestThreadTest from Scala to Java [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2026/03/10 01:33:30 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Devanshi Khatsuriya (Jira)" <ji...@apache.org> on 2026/03/10 02:47:00 UTC, 1 replies.
- Re: [PR] KAFKA-16959: ConfigCommand should allow to define both `entity-default` and `entity-name` [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 04:14:58 UTC, 0 replies.
- Re: [PR] KAFKA-17821: the set of configs displayed by `logAll` could be invalid [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 04:14:59 UTC, 0 replies.
- Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 04:15:02 UTC, 0 replies.
- Re: [PR] KAFKA-18981: Fix flaky test QuorumControllerTest.testMinIsrUpdateWithElr [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 04:15:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20291) Implement assignment batching - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/10 04:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20291) Implement assignment batchng - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/10 04:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20292) Implement assignor offload - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/10 04:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19880) First batch in producer epoch can be appended out-of-order even for idempotent producer - posted by "Travis Bischel (Jira)" <ji...@apache.org> on 2026/03/10 07:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19740) Depreacte broker-level config group.coordinator.rebalance.protocols - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 08:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20160) Group configuration for share.partition.max.record.locks - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/10 09:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-19149: Add KIP-877 support to MirrorMaker [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/10 10:06:04 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()` - posted by "Young Joo Kim (Jira)" <ji...@apache.org> on 2026/03/10 10:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-19212: Correct the unclean leader election metric calculation for 3.9 [kafka] - posted by "mmatloka (via GitHub)" <gi...@apache.org> on 2026/03/10 10:29:22 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20271) Initialize assignment epoch to -1 when there is no assignment yet - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/10 10:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20271) Initialize assignment epoch to -1 when there is no assignment yet - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/10 10:33:00 UTC, 0 replies.
- [PR] KAFKA-20269: Refactor assignment update for delayed consumer assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 12:20:50 UTC, 3 replies.
- [PR] KAFKA-20269: Refactor assignment update for delayed share assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 12:20:52 UTC, 0 replies.
- [PR] KAFKA-20269: Refactor assignment update for delayed streams assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 12:20:54 UTC, 2 replies.
- [PR] KAFKA-20266: Finish rename of TargetAssignmentEpoch record methods [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 12:55:31 UTC, 1 replies.
- Re: [PR] KAFKA-20135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/10 13:30:37 UTC, 0 replies.
- [PR] Update kraft readme [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2026/03/10 13:40:43 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20112) Flaky testAsyncConsumerMaxPollIntervalMsDelayInRevocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/10 13:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-20269 [3/N]: Refactor assignment update for delayed streams assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 13:41:17 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-20112) Flaky testAsyncConsumerMaxPollIntervalMsDelayInRevocation - posted by "Evan Zhou (Jira)" <ji...@apache.org> on 2026/03/10 13:59:00 UTC, 1 replies.
- [PR] MINOR Followup Deprecate group.coordinator.rebalance.protocols config [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/10 14:02:33 UTC, 0 replies.
- [PR] KAFKA-20268: Initialize group epochs to 1 for assignment offload [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/10 14:24:18 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/10 14:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-20269 [1/N]: Refactor assignment update for delayed consumer assignments [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/10 14:53:49 UTC, 0 replies.
- [jira] [Created] (KAFKA-20293) Add comprehensive Markdown documentation for CLI tools - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 15:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20293) Add comprehensive Markdown documentation for CLI tools - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 15:17:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20293) Add comprehensive Markdown documentation for CLI tools - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/03/10 15:24:00 UTC, 0 replies.
- [PR] MINOR: fix share poll event to call the share membership manager [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/10 15:28:05 UTC, 1 replies.
- Re: [PR] KAFKA-20269 [2/N]: Refactor assignment update for delayed share assignments [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/10 15:28:32 UTC, 3 replies.
- [jira] [Created] (KAFKA-20294) Metadata-Version-Aware Configuration Constraints - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 15:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20294) Metadata-Version-Aware Configuration Constraints - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 15:45:00 UTC, 1 replies.
- [PR] KAFKA-17840: Move ReplicationQuotaManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/10 16:27:58 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20281) Enhance docs and test coverage for `producer-props` and `command-property` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/10 17:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20162) Validation and enforcement of group configurations - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/10 19:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20290) Add KIP-1240 information to upgrade documentation - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/10 19:31:00 UTC, 0 replies.
- [PR] KAFKA-20290: KIP-1240 updates in upgrade.md [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/10 19:38:43 UTC, 1 replies.
- [PR] MINOR: Share consumer config heading [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/10 19:59:39 UTC, 2 replies.
- Re: [PR] KAFKA-13819: Add application.server to Streams assignor logs when set [kafka] - posted by "dubeyKartikay (via GitHub)" <gi...@apache.org> on 2026/03/10 20:28:01 UTC, 0 replies.
- [PR] Fix header-based key deserialization in MeteredTimestampedWindowStoreWithHeaders iterator methods [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/10 21:04:39 UTC, 0 replies.
- Re: [PR] KAFKA-20182 version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/10 21:57:27 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20182) Upgrade gradle to 9.3.x - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/10 22:03:00 UTC, 0 replies.
- Re: [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/03/10 22:08:47 UTC, 0 replies.
- Re: [PR] KAFKA-20134: Fix header-based key deserialization in MeteredTimestampedWindowStoreWithHeaders iterator methods [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/10 23:29:28 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20249) Optimize rawValue methods across all Deserializers - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/10 23:31:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20249) Optimize rawValue methods across all Deserializers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/11 00:12:00 UTC, 0 replies.
- Re: [PR] KAFKA-20277: Add session store with headers support for IQv2 [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/11 00:59:47 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-20249) Optimize rawValue methods across all Deserializers - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/11 02:22:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20199) Evaluate whether BrokerId metrics tag should be renamed to NodeId or split by role - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/11 03:22:00 UTC, 2 replies.
- Re: [PR] MM2: Implement Fault Tolerance for Log Truncation and Topic Reset [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 03:50:51 UTC, 0 replies.
- Re: [PR] KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 03:51:20 UTC, 1 replies.
- Re: [PR] KAFKA-19008 Remove scala version from artifacts [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:07 UTC, 2 replies.
- Re: [PR] KAFKA-19262 Add a test to verify all metrics naming pattern [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:09 UTC, 2 replies.
- Re: [PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:10 UTC, 1 replies.
- Re: [PR] KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:14 UTC, 2 replies.
- Re: [PR] KAFKA-19308: Add unit tests for OAuthBearerRefreshingLogin [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:15 UTC, 1 replies.
- Re: [PR] (WIP) KAFKA-17243:MetadataQuorumCommand describe to include CommittedVoters [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:15:19 UTC, 1 replies.
- [PR] KAFKA-20249: Optimize raw value extraction in headers-aware deserializers [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/03/11 08:29:06 UTC, 35 replies.
- [jira] [Created] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Roland Sommer (Jira)" <ji...@apache.org> on 2026/03/11 08:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Roland Sommer (Jira)" <ji...@apache.org> on 2026/03/11 08:39:00 UTC, 4 replies.
- [PR] KAFKA-20268: Fix merge conflict with KAFKA-20162 [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/11 09:29:02 UTC, 3 replies.
- Re: [PR] MINOR: Followup Deprecate group.coordinator.rebalance.protocols config [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/11 09:34:50 UTC, 0 replies.
- [PR] MINOR: Remove temporary internal config group.share.enable [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/03/11 10:51:22 UTC, 12 replies.
- [jira] [Commented] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring - posted by "Manikumar (Jira)" <ji...@apache.org> on 2026/03/11 13:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20037) Additional group configurations for share groups - posted by "Manikumar (Jira)" <ji...@apache.org> on 2026/03/11 14:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring - posted by "Manikumar (Jira)" <ji...@apache.org> on 2026/03/11 14:46:00 UTC, 0 replies.
- [PR] fix(docs): clean typos and grammar across quickstart, connect, streams, and MirrorMaker docs [kafka] - posted by "Zhang-Charlie (via GitHub)" <gi...@apache.org> on 2026/03/11 15:14:36 UTC, 1 replies.
- [PR] KAFKA-20261: Upgrade path for plain window store to headers store [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/11 15:43:45 UTC, 2 replies.
- [PR] MINOR: Share group tidying [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/11 16:02:49 UTC, 4 replies.
- Re: [PR] MINOR: Use a separate map to store acknowledgements in ShareAcknowledgementEvent. [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/11 16:03:15 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20090) TV2 can allow for ongoing transactions with max epoch that never complete - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2026/03/11 18:05:00 UTC, 0 replies.
- Re: [PR] KAFKA-20164: Add handleLoadBootstrap to KRaft [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/11 18:49:15 UTC, 10 replies.
- [jira] [Updated] (KAFKA-20296) Flaky testAsyncConsumerPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/11 19:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20296) Flaky testAsyncConsumerPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/11 19:12:00 UTC, 0 replies.
- Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/11 19:14:50 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19709) Add LegacyCheckpointingStateStore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/11 20:19:00 UTC, 0 replies.
- [PR] Hshi/track successful auto topic creation 20260311 [kafka] - posted by "hshi2022 (via GitHub)" <gi...@apache.org> on 2026/03/11 20:56:00 UTC, 1 replies.
- Re: [PR] KAFKA-19851 Delete dynamic config that were removed by Kafka [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/11 21:30:33 UTC, 35 replies.
- [jira] [Resolved] (KAFKA-20037) Additional group configurations for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/11 21:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20290) Add KIP-1240 information to upgrade documentation - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/11 21:40:00 UTC, 0 replies.
- [PR] KAFKA-20296: Fix flaky consumer metrics test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/11 23:01:20 UTC, 3 replies.
- Re: [PR] KAFKA-20194: Change KeyValueStoreWrapper to have versioned and headersStore [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/11 23:41:53 UTC, 14 replies.
- [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka] - posted by "mvanhorn (via GitHub)" <gi...@apache.org> on 2026/03/12 00:32:56 UTC, 4 replies.
- [PR] KAFKA-20237: Re-enqueue InitProducerId request after authentication failure [kafka] - posted by "mvanhorn (via GitHub)" <gi...@apache.org> on 2026/03/12 00:37:30 UTC, 1 replies.
- [PR] KAFKA-19906: Guard against null metric key in StreamsMetricsImpl [kafka] - posted by "mvanhorn (via GitHub)" <gi...@apache.org> on 2026/03/12 00:42:48 UTC, 5 replies.
- [PR] KAFKA-19697 NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close() [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/12 00:50:40 UTC, 2 replies.
- [PR] KAFKA-20199: Use NodeId selector metric tag on controller-only KRaft nodes [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/12 01:24:45 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20199) Evaluate whether BrokerId metrics tag should be renamed to NodeId or split by role - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/12 01:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20297) cleanup org.apache.kafka.common.utils - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/12 01:26:00 UTC, 0 replies.
- [PR] MINOR: Remove MappedIterator and test [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2026/03/12 01:43:41 UTC, 0 replies.
- [PR] KAFKA-20291 [1/3]: Implement assignment batching for consumer groups [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 02:50:35 UTC, 7 replies.
- [PR] KAFKA-20291 [2/3]: Implement assignment batching for share groups [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 02:50:39 UTC, 4 replies.
- [PR] KAFKA-20291 [3/3]: Implement assignment batching for streams groups [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 02:50:46 UTC, 13 replies.
- [jira] [Resolved] (KAFKA-20268) Start group epochs at 2 - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/12 02:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20269) Refactor GroupMetadataManager assignment updates - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/12 02:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20298) Update integration tests to run with combinations of assignment batching and offload - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/12 03:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - client (2/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/12 04:16:16 UTC, 1 replies.
- Re: [PR] KAFKA-19884: Add tests to ensure Consumer.close() timeouts work as documented [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/12 04:29:00 UTC, 1 replies.
- [PR] Apache kafka 14147 [kafka] - posted by "shiva2405 (via GitHub)" <gi...@apache.org> on 2026/03/12 04:42:11 UTC, 1 replies.
- [PR] MINOR: improve StreamsConfig client-tags verification [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/12 04:50:01 UTC, 5 replies.
- [PR] KAFKA-20116: Send client.rack via StreamsHeartbeatRequest [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/12 06:11:10 UTC, 3 replies.
- [PR] MINOR: replace mkMap/mkEntry with Map.of/Map.entry in clients module [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2026/03/12 06:23:27 UTC, 14 replies.
- [PR] KAFKA-20292 [2/N]: Handle membership changes during offloaded streams assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 06:54:06 UTC, 1 replies.
- [PR] KAFKA-20292 [1/N]: Handle membership changes during offloaded assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 06:54:49 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20297) cleanup org.apache.kafka.common.utils - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/12 09:01:00 UTC, 2 replies.
- [PR] MINOR: Fix log messages for epoch comparison in ReplicationControlManager [kafka] - posted by "giuseppelillo (via GitHub)" <gi...@apache.org> on 2026/03/12 09:23:21 UTC, 2 replies.
- [PR] KAFKA-20251 [1/N]: Add broker configs for assignment batching and offload [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 09:31:33 UTC, 2 replies.
- [jira] [Created] (KAFKA-20299) Cleanup `use_share_groups` in system tests - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/03/12 10:28:00 UTC, 0 replies.
- [PR] KAFKA-20117: Improve ClusterControlManager error message [kafka] - posted by "Rancho-7 (via GitHub)" <gi...@apache.org> on 2026/03/12 10:44:00 UTC, 2 replies.
- [PR] MINOR: Correct default config in test [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/12 11:22:24 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20201) Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type - posted by "Chaemin Lee (Jira)" <ji...@apache.org> on 2026/03/12 11:26:00 UTC, 0 replies.
- Re: [PR] KAFKA-20201: Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type [kafka] - posted by "CokeLee777 (via GitHub)" <gi...@apache.org> on 2026/03/12 11:26:48 UTC, 1 replies.
- [jira] [Created] (KAFKA-20300) Add assignment batching and offload broker configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/12 13:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-18608: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka] - posted by "omkreddy (via GitHub)" <gi...@apache.org> on 2026/03/12 13:04:30 UTC, 2 replies.
- Re: [PR] KAFKA-20300: Add broker configs for assignment batching and offload [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/12 13:11:06 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-19884) Add tests to ensure Consumer.close() timeouts work as documented - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/12 14:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20296) Flaky testAsyncConsumerPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/12 16:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20289) Broker configs with group config names masquerading as static broker config - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/12 16:47:00 UTC, 2 replies.
- [PR] MINOR: Flaky testDynamicPartitionMaxRecordLocks [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/12 16:58:40 UTC, 1 replies.
- [PR] KAFKA-20158: Fix header-based key deserialization in MeteredSessionStoreWithHeaders iterator methods [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/12 17:17:23 UTC, 3 replies.
- [PR] KAFKA-15370: Support Participation in 2PC (KIP-939) (K/N) [kafka] - posted by "artemlivshits (via GitHub)" <gi...@apache.org> on 2026/03/12 17:20:08 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-18652) Extended set of streams-specific broker configurations - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/12 17:25:00 UTC, 0 replies.
- [PR] KAFKA-20132: Fix header-based key deserialization in MeteredTimestampedKeyValueStoreWithHeaders iterator methods [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/12 18:05:40 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-18972) Custom Processor supplied on addReadOnlyStateStore is not used when restoring state from topic - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/12 19:21:00 UTC, 1 replies.
- Re: [PR] MINOR: version update: 4.1.1 -->> 4.2.0 [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/12 19:34:44 UTC, 1 replies.
- [PR] KAFKA-18652: Add `task.offset.interval.ms` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/12 19:39:48 UTC, 13 replies.
- [jira] [Updated] (KAFKA-19884) Add tests to ensure Consumer.close() timeouts work as documented - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/12 19:40:00 UTC, 0 replies.
- [PR] KAFKA-19712: ProcessorStateManager delegates offset tracking to stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/12 20:21:19 UTC, 10 replies.
- [PR] KAFKA-20257: GlobalStateManagerImpl delegates offset tracking to stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/12 20:24:12 UTC, 9 replies.
- [jira] [Created] (KAFKA-20301) Integration tests for upgrade and downgrade SessionStore with headers - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/12 20:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/12 21:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20302) Receive buffers allocated from MemoryPool may not be released if request is invalid - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/03/13 00:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20302) Receive buffers allocated from MemoryPool may not be released if request is invalid - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/03/13 00:42:00 UTC, 3 replies.
- [PR] KAFKA-20302: Receive buffers allocated from MemoryPool may not be released if request is invalid [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2026/03/13 02:16:02 UTC, 36 replies.
- [jira] [Commented] (KAFKA-20292) Implement assignor offload - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/13 03:49:00 UTC, 0 replies.
- Re: [PR] KAFKA-20035 Prevent data loss during partition expansion for dynamically added partitions (WIP) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/13 03:50:56 UTC, 1 replies.
- Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/13 04:15:46 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning - posted by "Aman Ahmad (Jira)" <ji...@apache.org> on 2026/03/13 04:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20261) Upgrade path for plain window store to headers store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 05:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20132) Implement TimestampedKeyValueStoreWithHeaders - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 05:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20134) Implement TimestampedWindowStoreWithHeaders - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 05:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20158) Implement SessionStoreWithHeaders - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 05:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 05:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 07:43:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 07:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20300) Add assignment batching and offload broker configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/13 07:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20251) Add group-level assignment batching and offload configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/13 07:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20303) Optimize deserializers and HeadersBytesStore - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 08:14:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20303) optimize deserializers and HeadersBytesStore - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 08:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20303) Optimize deserializers and HeadersBytesStore - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 08:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20079) Improve Connect configurable components discoverability - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/13 09:20:00 UTC, 0 replies.
- [PR] MINOR: Add project details in asf.yaml [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/13 09:34:37 UTC, 1 replies.
- [PR] MINOR : Added close() in ShareConsumeBenchWorker::stop() to handle interrupts cleanly. [kafka] - posted by "ShivsundarR (via GitHub)" <gi...@apache.org> on 2026/03/13 09:55:48 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20304) Implement all required ReadOnly*Facade classes - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 10:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20304) Implement all required ReadOnly*Facade classes - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 10:52:00 UTC, 0 replies.
- [PR] KAFKA-20304: Implement all required ReadOnly*Facade classes for headers stores [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/13 10:52:34 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20304) Implement all required ReadOnly*Facade classes for headers stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 10:53:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20305) clampDynamicConfigs flag for KafkaConfigs constructor - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/13 12:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20306) StreamsGroupCommand does not display committed offsets for repartition topics - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/13 12:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20306) StreamsGroupCommand does not display committed offsets for repartition topics - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/03/13 12:35:00 UTC, 1 replies.
- Re: [PR] KAFKA-20297 Remove MappedIterator and test [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/03/13 12:45:15 UTC, 1 replies.
- [jira] [Created] (KAFKA-20307) Add Interactive Queries (IQv1) support for headers-aware stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 13:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20307) Add Interactive Queries (IQv1) support for headers-aware stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 13:10:00 UTC, 0 replies.
- [PR] KAFKA-20307: Add Interactive Queries (IQv1) support for headers-aware stores [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/13 13:10:42 UTC, 6 replies.
- [jira] [Created] (KAFKA-20308) Update TopologyTestDriver to support for headers-aware stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 13:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20308) Update TopologyTestDriver to support for headers-aware stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 13:27:00 UTC, 0 replies.
- [PR] KAFKA-20308: Update TopologyTestDriver to support for headers-aware stores [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/13 13:27:32 UTC, 3 replies.
- [jira] [Created] (KAFKA-20309) Too many SharePollEvents created - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/13 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 14:43:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-20171) Support regular expression topic patterns for streams groups - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/13 14:46:00 UTC, 0 replies.
- [PR] KAFKA-20112: Fix flaky consumer callback/position test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/13 14:49:48 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-20171) Support regular expression topic patterns for streams groups - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/13 14:50:00 UTC, 5 replies.
- [PR] fix: architecture detection for Kafka heap options [kafka] - posted by "yunnysunny (via GitHub)" <gi...@apache.org> on 2026/03/13 14:53:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 15:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 15:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20056) Allow to Store Record Headers in State Stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/13 15:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-20251: Add group-level configs for assignment batching and offload [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/03/13 15:51:08 UTC, 15 replies.
- [jira] [Commented] (KAFKA-20299) Cleanup `use_share_groups` in system tests - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/13 15:58:00 UTC, 4 replies.
- [PR] KAFKA-20301: Upgrade downgrade integration tests for session store with headers [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/13 16:33:08 UTC, 4 replies.
- [PR] KAFKA:20158: Parameterize session store unit tests to run with headers-aware store format [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/13 16:45:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20219) Override `getPosition` correctly for TimestampedKeyValueStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/13 16:56:00 UTC, 1 replies.
- [PR] Store position into offsets CF [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2026/03/13 17:27:04 UTC, 0 replies.
- [PR] Fix CF handle leaks [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/13 19:13:06 UTC, 6 replies.
- [jira] [Updated] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/13 19:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20287) Verify (and potentially fix) if all CF handles (and other objects) are closed correctly - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/13 19:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20301) Integration tests for upgrade and downgrade SessionStore with headers - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 20:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20307) Add Interactive Queries (IQv1) support for headers-aware stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 20:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20308) Update TopologyTestDriver to support for headers-aware stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 20:22:00 UTC, 0 replies.
- [PR] MINOR: add docs redirect [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/13 21:54:50 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/13 23:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-19713: Persist Position into offsets CF [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/14 00:04:04 UTC, 6 replies.
- [jira] [Created] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log - posted by "Artem Livshits (Jira)" <ji...@apache.org> on 2026/03/14 02:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log - posted by "Artem Livshits (Jira)" <ji...@apache.org> on 2026/03/14 02:37:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log - posted by "Artem Livshits (Jira)" <ji...@apache.org> on 2026/03/14 02:45:00 UTC, 1 replies.
- [PR] KAFKA-20297: move Scheduler from client common to trogdor [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/03/14 02:53:13 UTC, 0 replies.
- Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/14 03:50:31 UTC, 0 replies.
- Re: [PR] [WIP] Draft proposal for adding retries to timed out KS EOS commit requests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/14 04:15:19 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20049) kafka-site build depends on hvishwanath/hugo - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/03/14 05:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20311) Cached metered key-value stores can deserialize old values with the wrong headers when sendOldValues=true - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/14 06:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20311) Cached metered key-value stores can deserialize old values with the wrong headers when sendOldValues=true - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/14 06:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20311) Cached metered key-value stores can deserialize old values with the wrong headers when sendOldValues=true - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/14 06:14:00 UTC, 7 replies.
- [jira] [Comment Edited] (KAFKA-20311) Cached metered key-value stores can deserialize old values with the wrong headers when sendOldValues=true - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/14 06:16:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19883) Support Hierarchical Transactional Acknowledgments for Share Groups - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/14 07:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20312) KafkaConsumer poll may happens NullPointerException - posted by "guwensheng (Jira)" <ji...@apache.org> on 2026/03/14 07:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20312) KafkaConsumer poll may happens NullPointerException - posted by "guwensheng (Jira)" <ji...@apache.org> on 2026/03/14 07:28:00 UTC, 3 replies.
- [PR] KAFKA-20278 : Refactor setup pattern, PART-1 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/14 09:02:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/14 09:04:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19937) Use the same reaper thread in Persister as well as NetworkPartitionMetadataClient - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/14 12:13:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-19937) Use the same reaper thread in Persister as well as NetworkPartitionMetadataClient - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/14 12:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20312) KafkaConsumer poll may happens NullPointerException - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/14 14:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20312) KafkaConsumer poll may happens NullPointerException - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/14 14:37:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/14 14:49:00 UTC, 0 replies.
- Re: [PR] [WIP] KAFKA-20197: Headers support for StreamPartitioner [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/14 18:44:15 UTC, 0 replies.
- Re: [PR] MINOR: Clean up RemoteLogManagerTest.testCopyQuota [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/14 18:44:19 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20222) Enable SessionStoreWithHeaders in DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/14 18:53:00 UTC, 0 replies.
- [PR] KAFKA-20173: Propagate headers into serde 4/N [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/14 19:06:24 UTC, 6 replies.
- [PR] KAFKA-20173: Propagate headers into serde 5/N [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/14 19:49:59 UTC, 4 replies.
- [PR] KAFKA-20309: Limit SharePollEvent to single instance [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/14 21:59:17 UTC, 3 replies.
- [PR] KAFKA-20288: Remove orphaned groups from GroupConfigManager [kafka] - posted by "jack2012aa (via GitHub)" <gi...@apache.org> on 2026/03/15 00:34:55 UTC, 9 replies.
- [PR] MINOR: add missing overrides on TTD store facades [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/15 00:46:44 UTC, 1 replies.
- Re: [PR] KAFKA-20158: Parameterize session store unit tests to run with headers-aware store format [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/15 01:01:21 UTC, 2 replies.
- [jira] [Created] (KAFKA-20313) Cleanup "leaking" internal interface `WindowedSerializer` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/15 01:42:00 UTC, 0 replies.
- Re: [PR] [WIP] KAFKA-20173: Propagate headers into serde 5/N [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/15 02:04:28 UTC, 4 replies.
- [PR] KAFKA-20312: Handle null leader during OffsetFetcher regroup safely [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/15 03:40:24 UTC, 1 replies.
- Re: [PR] KAFKA-20176: Add MetaProperties V2 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:02:00 UTC, 0 replies.
- Re: [PR] POC: conditional creation of internal topics in Kafka Connect [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:19:06 UTC, 1 replies.
- Re: [PR] KAFKA-19853: commit open tasks before handling assignment [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:19:10 UTC, 1 replies.
- Re: [PR] KAFKA-17798: Add forbidden-apis linting to gradle build [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:19:14 UTC, 1 replies.
- Re: [PR] KAFKA-16263 Add Kafka Streams docs about available listeners/callback [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:19:16 UTC, 1 replies.
- Re: [PR] MINOR: Add MockProducer and MockConsumer testing examples [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 04:19:19 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20301) Integration tests for upgrade and downgrade SessionStore with headers - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/15 04:33:00 UTC, 0 replies.
- [PR] KAFKA-19752: Move UnifiedLogTest to storage module [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2026/03/15 06:38:43 UTC, 11 replies.
- [PR] MINOR: perf optimization for header serialization and type conversion [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/15 07:45:47 UTC, 17 replies.
- [jira] [Commented] (KAFKA-20313) Cleanup "leaking" internal interface `WindowedSerializer` - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/15 10:37:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-20313) Cleanup "leaking" internal interface `WindowedSerializer` - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/15 10:39:00 UTC, 0 replies.
- Re: [PR] Clone kafka 18894 [kafka] - posted by "coderabbit-test (via GitHub)" <gi...@apache.org> on 2026/03/15 12:17:25 UTC, 0 replies.
- [PR] MINOR: Fix typo 'curent' to 'current' in LeaderState [kafka] - posted by "xxxxxxjun (via GitHub)" <gi...@apache.org> on 2026/03/15 14:24:55 UTC, 1 replies.
- [PR] KAFKA: Clarify allow.everyone.if.no.acl.found documentation [kafka] - posted by "Saad10Codes (via GitHub)" <gi...@apache.org> on 2026/03/15 15:15:23 UTC, 2 replies.
- [PR] KAFKA-20246: Detection and handling of misrouted connections [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/15 15:24:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20050) Add syntax highlighting for code blocks and commands - posted by "gomudayya (Jira)" <ji...@apache.org> on 2026/03/15 15:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20311) Cached metered key-value stores can deserialize old values with the wrong headers when sendOldValues=true - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/15 18:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20313) Cleanup "leaking" internal interface `WindowedSerializer` - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/03/15 21:00:00 UTC, 0 replies.
- [PR] MINOR: code cleanup [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/16 02:03:41 UTC, 3 replies.
- [PR] KAFKA-20173: Ensure Metered kv-stores pass headers correctly [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/16 02:08:13 UTC, 13 replies.
- [PR] KAFKA-20303: Optimize deserializers and HeadersBytesStore [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/03/16 03:30:39 UTC, 4 replies.
- Re: [PR] MINOR: Enable auth test for new consumer [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/16 04:24:27 UTC, 0 replies.
- Re: [PR] Mm2 fault tolerance enhancement [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/16 04:24:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18536) Flaky ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/16 07:42:00 UTC, 0 replies.
- [PR] KAFKA-20211: Fix group coordinator background metrics test flake [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/16 08:58:05 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-20299) Cleanup `use_share_groups` in system tests - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/03/16 09:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/16 10:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20314) Segmentation fault when starting kafka-native - posted by "Piotr Przybylski (Jira)" <ji...@apache.org> on 2026/03/16 11:08:00 UTC, 0 replies.
- [PR] MINOR: Update javadocs for GroupConfig and GroupConfigManager [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/16 11:16:43 UTC, 4 replies.
- Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/16 11:49:00 UTC, 3 replies.
- [PR] MINOR: Add streams group tests to GroupCoordinatorIntegrationTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/03/16 14:02:57 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/16 14:31:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/16 14:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/16 14:37:00 UTC, 1 replies.
- [PR] KAFKA-20216: Shadow Jetty dependencies to decouple from SLF4J version conflict [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/03/16 14:40:10 UTC, 0 replies.
- [jira] [Created] (KAFKA-20316) Rewrite AddPartitionsTest with ClusterInstance - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 15:12:00 UTC, 0 replies.
- Re: [PR] KAFKA-20287 : Fix CF handle leaks [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/16 15:20:22 UTC, 21 replies.
- [jira] [Commented] (KAFKA-20316) Rewrite AddPartitionsTest with ClusterInstance - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 15:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-20168: Downgrade Jetty from 12.0.32 to 12.0.25 to fix SLF4J 2.x incompatibility (4.1) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/16 15:24:36 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19697) NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close() - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 15:36:00 UTC, 1 replies.
- Re: [PR] KAFKA-20168: Add comment to explain why we don't upgrade jetty version [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/03/16 15:40:36 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19697) NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close() - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 15:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19697) NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close() - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 15:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20247) ControllerRegistrationManager does not retry registration after timing out - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/03/16 16:09:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20247) ControllerRegistrationManager does not retry registration after timing out - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/03/16 16:19:00 UTC, 0 replies.
- [PR] MINOR: Fix bug where dslStoreFormat is non-null and always set to HEADERS [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/16 16:32:19 UTC, 2 replies.
- [jira] [Created] (KAFKA-20318) Enable time-ordered header window store in DSL - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/16 16:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20317) Enable time-ordered header window store in DSL - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/16 16:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20317) Enable time-ordered header window store in DSL - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/16 16:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20318) Enable time-ordered header session store in DSL - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/16 16:52:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20212) Add offset management support to RocksDBStore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/16 17:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19714) Auto migrate .checkpoint offsets - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/16 17:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-13499) Avoid restoring outdated records - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/03/16 17:55:00 UTC, 0 replies.
- [PR] KAFKA-19712: Simplify StateManager interface and checkpoint logic [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/16 18:21:11 UTC, 2 replies.
- [jira] [Created] (KAFKA-20319) Discuss the silent overwrite behavior of duplicate keys in kafka-configs.sh - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 18:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20319) Discuss the silent overwrite behavior of duplicate keys in kafka-configs.sh - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/16 18:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20309) Too many SharePollEvents created - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/16 19:01:00 UTC, 0 replies.
- Re: [PR] KAFKA-20168: Add comment to explain why we don't upgrade jetty version (4.1) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/16 19:01:11 UTC, 0 replies.
- Re: [PR] KAFKA-20168: Add comment to explain why we don't upgrade jetty version (4.0) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/16 19:01:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/03/16 19:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/03/16 19:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20321) Mark partitions lost to avoid potential race with buffered records - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/16 19:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20322) TransactionMarkerChannelManager has discoverBrokerVersions=false causing UnsupportedVersionException during rolling upgrades - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2026/03/16 19:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20322) TransactionMarkerChannelManager has discoverBrokerVersions=false causing UnsupportedVersionException during rolling upgrades - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2026/03/16 19:45:00 UTC, 10 replies.
- [PR] KAFKA-13499: Avoid restoring outdated records [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/03/16 20:04:11 UTC, 13 replies.
- [jira] [Created] (KAFKA-20323) Refactor "ShareCoordinatorServiceTest.testRecordPruningTaskPeriodicityWithSomeFailures()" test method in order to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 20:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20323) Refactor test method in order to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 20:21:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-20323) Refactor test method in order to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 20:32:00 UTC, 0 replies.
- [jira] (KAFKA-20323) Refactor test method in order to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 20:33:00 UTC, 0 replies.
- [PR] KAFKA-20317: Enable time-ordered header window store in DSL [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/16 20:56:19 UTC, 8 replies.
- [PR] KAFKA-20321: Mark lost partitions before callbacks for Consumer and Streams [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/16 21:14:42 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20323) Refactor test method to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 21:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20323) Refactor test method to enable Mockito version upgrade - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/16 21:56:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20302) Receive buffers allocated from MemoryPool may not be released if request is invalid - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/03/16 22:57:00 UTC, 0 replies.
- [PR] KAFKA-20322: Add API version discovery true for transaction manager [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2026/03/17 00:43:30 UTC, 0 replies.
- [PR] Remove obsolete share-group enable opt-ins from system tests [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/17 00:48:18 UTC, 0 replies.
- Re: [PR] KAFKA-20194: Update Kafka Streams DSL to use header-stores [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/17 00:51:39 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20319) Discuss the silent overwrite behavior of duplicate keys in kafka-configs.sh - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/17 01:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/17 01:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/17 01:43:00 UTC, 1 replies.
- [PR] KAFKA-20258 Refactor DSL store config and propagate dslStoreFormat [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/03/17 03:21:16 UTC, 2 replies.
- Re: [PR] KAFKA-20165 [2]: Integration tests to validate different OffsetFetch response behaviour on topic deleted [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2026/03/17 03:39:25 UTC, 2 replies.
- Re: [PR] KAFKA-18874: Fix KRaft controller registration retry on timeout [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 04:17:02 UTC, 1 replies.
- Re: [PR] KAFKA-19971: Fix IllegalStateException from using entries after cache eviction [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 04:17:08 UTC, 0 replies.
- Re: [PR] KAFKA-19969: Add Per-Topic Observability Metrics for Remote Fetch Quota Enforcement [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 04:17:11 UTC, 0 replies.
- Re: [PR] KAFKA-19967: Reduce GC pressure in tiered storage read path using direct memory buffers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 04:17:13 UTC, 0 replies.
- Re: [PR] KAFKA-19878 : Connect | Fixed order of arguments in assertEquals in connect package [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 04:17:15 UTC, 1 replies.
- [jira] [Commented] (KAFKA-18574) Quarantined test list should be sorted - posted by "陈哲凯 (Jira)" <ji...@apache.org> on 2026/03/17 07:04:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20288) Remove orphaned groups from GroupConfigManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/17 07:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20324) Update docs to reflect relaxed formatting requirements - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/17 07:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20324) Update docs to reflect relaxed formatting requirements - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/17 07:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20256) DLQManager interace and default impl - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/03/17 07:37:00 UTC, 0 replies.
- [PR] KAFKA-20245: Add throwables and new record state for share group DLQ. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/03/17 08:08:41 UTC, 3 replies.
- [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka] - posted by "wrmxs227 (via GitHub)" <gi...@apache.org> on 2026/03/17 08:44:48 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-19149) Use KIP-877 in MirrorMaker - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/17 08:58:00 UTC, 0 replies.
- [PR] Kafka 20245 2 [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/03/17 09:26:05 UTC, 0 replies.
- Re: [PR] KAFKA-20299: Remove use_share_groups from system tests [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/03/17 11:20:53 UTC, 0 replies.
- [PR] MINOR: Remove unused ReadonlyXxFacade classes [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/17 11:34:14 UTC, 0 replies.
- [PR] MINOR: Add 4.1.2 to the CVE Scanner [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/17 12:10:11 UTC, 0 replies.
- [jira] [Created] (KAFKA-20325) apache/kafka image - cannot set SSL as protocol for CONTROLLER on dedicated controller - posted by "Neil Buesing (Jira)" <ji...@apache.org> on 2026/03/17 12:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20326) WindowStoreMaterializerTests should pass - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 14:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20326) WindowStoreMaterializerTests should pass - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 14:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20326) WindowStoreMaterializerTests should pass - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 14:00:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20277) Verify existing IQv2 methods for SessionStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/17 14:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20327) Add SessionStore overrides to Abstract decorators - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/17 14:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20327) Add SessionStore overrides to Abstract decorators - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/17 14:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18824) Update docs of docker hub to add dynamic voters description - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/17 14:35:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20124) Move LogCleanerLagIntegrationTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/17 15:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20327) Add SessionStore overrides to Abstract decorators - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/17 15:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20326) WindowStoreMaterializerTests needs to get updated - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/17 15:45:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20318) Enable time-ordered header session store in DSL - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/17 16:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20287) Verify (and potentially fix) if all CF handles (and other objects) are closed correctly - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/17 16:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20220) Enable TimestampedKVStoreWithHeaders in DSL - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 17:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 17:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 18:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 18:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 18:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20327) Add SessionStore overrides to Abstract decorators - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 18:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20327) Add SessionStore overrides to Abstract decorators - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/17 18:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20299) Cleanup `use_share_groups` in system tests - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/17 19:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/17 21:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/03/17 22:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19863) Add documentation on how to implement a custom exception handler - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/03/17 22:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/17 22:56:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/18 00:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18574) Quarantined test list should be sorted - posted by "陈哲凯 (Jira)" <ji...@apache.org> on 2026/03/18 06:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19756) Write down the steps for upgrading Gradle - posted by "Chih-Yuan Chien (Jira)" <ji...@apache.org> on 2026/03/18 08:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19856) Stabilize ClientUtilsTest.testParseAndValidateAddressesWithReverseLookup - posted by "Chih-Yuan Chien (Jira)" <ji...@apache.org> on 2026/03/18 08:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19756) Write down the steps for upgrading Gradle - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/18 09:13:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20329) Test `headers` format further - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/18 12:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20329) Test `headers` format further - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/18 12:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20329) Test `headers` format further - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/18 12:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20329) Test `headers` dsl.store.format further - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/18 12:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14487) Move LogManager to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/18 13:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20330) Share partition leader restart without leadership change gives wrong exception - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/18 14:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20322) TransactionMarkerChannelManager has discoverBrokerVersions=false causing UnsupportedVersionException during rolling upgrades - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/18 15:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20240) Update upgrade.md to mention new batching configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/18 15:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20331) Update upgrade.md to mention new assignment offload configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/18 15:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20240) Update upgrade.md to mention new batching and background thread pool configs - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/18 15:30:00 UTC, 1 replies.
- Re: [PR] MINOR: Deflake Headers store upgrade integration test [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/18 15:44:47 UTC, 0 replies.
- [PR] MINOR: Remove unused createNetworkClient overload in ClientUtils [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/18 16:40:49 UTC, 1 replies.
- Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/18 16:46:53 UTC, 5 replies.
- Re: [PR] MINOR: Revise Topic Resolving Logic in OffsetCommit Request to Prevent Race Condition [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/03/18 16:55:42 UTC, 1 replies.
- [PR] KAFKA-20291 [4/N]: Fix consumer system tests [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/18 17:41:57 UTC, 1 replies.
- [jira] [Created] (KAFKA-20332) Ensure app thread not collecting records for partitions being revoked - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/18 17:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-17411: Fix issues with new offset management [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/18 18:22:54 UTC, 2 replies.
- [PR] KAFKA-20329: Test headers dsl.store.format further (2/N) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/18 18:39:10 UTC, 1 replies.
- [PR] KAFKA-20106 [2/2]: Ensure reconciled assignment updated within poll KS [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/18 18:43:56 UTC, 10 replies.
- [PR] KAFKA-19710: Write legacy .checkpoint on close for downgrade support [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/03/18 19:09:43 UTC, 4 replies.
- Re: [PR] KAFKA-20164; Add bootstrap support to KRaft listener interface [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/18 19:17:47 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20164) Add Kraft layer support for snapshots with metadata records via new handleLoadBootstrap - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/03/18 19:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20333) Flaky runCloseClassicConsumerMultiConsumerSessionTimeoutTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/18 20:09:00 UTC, 0 replies.
- [PR] KAFKA-20333: Fix flaky consumer test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/18 20:37:44 UTC, 1 replies.
- Re: [PR] MINOR: misc improvements in consumer test & events [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/18 20:39:38 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20117) Improve ClusterControlManager error message - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/18 21:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/18 23:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/03/19 00:32:00 UTC, 0 replies.
- Re: [PR] KAFKA-19914: Move AlterPartitionManager to server module [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/19 03:55:31 UTC, 1 replies.
- [jira] [Created] (KAFKA-20335) Update docs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/19 04:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20336) Update docs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/19 04:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20335) Update docs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/19 04:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-18652: Add `acceptable.recovery.lag` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/19 04:10:20 UTC, 4 replies.
- Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/19 04:17:48 UTC, 3 replies.
- Re: [PR] KAFKA-20318: Add time ordered session store support to the DSL [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/19 05:35:47 UTC, 6 replies.
- Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/03/19 08:07:37 UTC, 9 replies.
- Re: [PR] MINOR: clean typos and grammar across quickstart, connect, streams, and MirrorMaker docs [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/19 08:28:58 UTC, 1 replies.
- Re: [PR] KAFKA-15853: [1/N] Move static methods, SocketServer and Log configs to AbstractKafkaConfig [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/19 08:49:26 UTC, 7 replies.
- [jira] [Updated] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/03/19 09:15:00 UTC, 0 replies.
- [PR] MINOR: Use mutable maps in Fetch.forPartition to avoid potential UnsupportedOperationException [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/03/19 09:54:26 UTC, 10 replies.
- [jira] [Created] (KAFKA-20337) Refactor GroupConfig to be less confusing - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/19 10:05:00 UTC, 0 replies.
- [PR] KAFKA-20306: StreamsGroupCommand should display committed offsets for repartition topics [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/19 10:06:27 UTC, 1 replies.
- [PR] KAFKA-20297: Cleanup `org.apache.kafka.common.utils.CollectionUtils` [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/03/19 10:13:01 UTC, 13 replies.
- [jira] [Resolved] (KAFKA-19710) Add downgrade support - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/03/19 10:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/03/19 10:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19713) Auto migrate .position offsets - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/03/19 10:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19712) Implement new behaviour in ProcessorStateManager - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/03/19 10:27:00 UTC, 0 replies.
- Re: [PR] KAFKA-13022: Optimize ClientQuotasImage#describe [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/19 10:29:15 UTC, 3 replies.
- [PR] feat: Enhanced MirrorMaker 2 with fault tolerance [kafka] - posted by "chellaraomadine-dev (via GitHub)" <gi...@apache.org> on 2026/03/19 10:41:53 UTC, 1 replies.
- [PR] KAFKA-20329: Test headers dsl.store.format further (3/N) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/19 10:53:08 UTC, 1 replies.
- [jira] [Created] (KAFKA-20338) Add benchmarking support to RaftClientTestContext - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/19 11:07:00 UTC, 0 replies.
- [PR] MINOR: Bump trunk to 4.4.0-SNAPSHOT [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/19 11:08:45 UTC, 5 replies.
- [PR] KAFKA-20240: Update upgrade.md for new KIP-1263 configs in 4.3 [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/03/19 11:56:30 UTC, 1 replies.
- [PR] MINOR: Cleanups in Tools module [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/03/19 12:53:09 UTC, 2 replies.
- Re: [PR] KAFKA-19648: KIP-1170 Unify cluster metadata bootstrapping [kafka] - posted by "mannoopj (via GitHub)" <gi...@apache.org> on 2026/03/19 12:58:23 UTC, 13 replies.
- [jira] [Resolved] (KAFKA-20251) Add group-level assignment batching and offload configs - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/19 14:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20339) Make offload config private for 4.3 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/19 14:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20282) Classic consumer log recommendation for next gen Consumer rebalance protocol - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/19 16:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20340) SharePartition should keep only one config reference - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/19 16:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20340) SharePartition should keep only one config reference - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/19 16:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/19 16:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20075) Side effects of 'preferred leader election' schedule change - posted by "Saravanan (Jira)" <ji...@apache.org> on 2026/03/19 17:23:00 UTC, 0 replies.
- Re: [PR] KAFKA-19542: Consumer.close() does not remove all added sensors from Metrics [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/19 17:49:54 UTC, 2 replies.
- [PR] KAFKA-20330: Ack handling improvement on broker restart [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/19 17:54:57 UTC, 5 replies.
- [jira] [Created] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/19 18:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20317) Enable time-ordered header window store in DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/19 18:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20318) Enable time-ordered header session store in DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/19 18:36:00 UTC, 0 replies.
- Re: [PR] KAFKA-19193 Support rack-aware partitioning for Kafka producer [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/19 19:08:22 UTC, 5 replies.
- [PR] KAFKA-20326: WindowStoreMaterializerTests needs to get updated [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/19 19:17:14 UTC, 4 replies.
- [jira] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Preethi KCS (Jira)" <ji...@apache.org> on 2026/03/19 19:21:00 UTC, 0 replies.
- [PR] Fail fast if application.id does not exist as consumer group in StreamsResetter [kafka] - posted by "Preethi-Sundaravelu (via GitHub)" <gi...@apache.org> on 2026/03/19 19:34:33 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20276) API to read data between offsets - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/19 19:44:00 UTC, 0 replies.
- [PR] KAFKA-20329: Test headers dsl.store.format further (4/N) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/19 22:05:05 UTC, 1 replies.
- [jira] [Created] (KAFKA-20342) Kafka Clients performance degradation - posted by "Tomasz (Jira)" <ji...@apache.org> on 2026/03/19 22:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20342) Kafka Clients performance degradation - posted by "Tomasz (Jira)" <ji...@apache.org> on 2026/03/19 22:18:00 UTC, 0 replies.
- [PR] KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log [kafka] - posted by "haltandcatchwater (via GitHub)" <gi...@apache.org> on 2026/03/19 22:38:23 UTC, 15 replies.
- [jira] [Commented] (KAFKA-20342) Kafka Clients performance degradation - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/19 23:25:00 UTC, 1 replies.
- [PR] MINOR: simplify window-byte-store-supplier [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/19 23:50:37 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/20 00:00:02 UTC, 0 replies.
- Re: [PR] KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 00:01:21 UTC, 8 replies.
- Re: [PR] KAFKA-20263: Change KeyValueStoreWrapper to have versioned and headersStore [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 00:20:07 UTC, 7 replies.
- [jira] [Commented] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/20 01:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20340) SharePartition should keep only one config reference - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/20 01:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 01:18:38 UTC, 25 replies.
- [PR] KAFKA-20224: Deduplicate ToHeaders iterator adapters with MappingKeyValueIteratorAdapter [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/20 02:18:32 UTC, 0 replies.
- [jira] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/20 02:29:00 UTC, 0 replies.
- [PR] MM2: Add offset gap detection and basic topic reset handling in MirrorSourceTask [kafka] - posted by "PoojanSmart (via GitHub)" <gi...@apache.org> on 2026/03/20 03:38:46 UTC, 1 replies.
- Re: [PR] KAFKA-19331: Fix misleading log messages when follower's leader is not in metadata image [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 03:51:36 UTC, 0 replies.
- Re: [PR] KAFKA-19982 : Raft package assertEquals argument adjustments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 03:51:38 UTC, 0 replies.
- Re: [PR] KAFKA-19968: Fix tiered storage quota enforcement issues [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 03:51:40 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20326) WindowStoreMaterializerTests needs to get updated - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/20 03:52:00 UTC, 0 replies.
- Re: [PR] MINOR: Update Protocol Buffers documentation URLs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 03:52:05 UTC, 0 replies.
- Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 03:58:34 UTC, 6 replies.
- Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 04:16:05 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20335) Update docs - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/20 06:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20335) Update docs - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/20 06:57:00 UTC, 0 replies.
- [PR] MINOR: Consumer tidying [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/20 08:20:12 UTC, 9 replies.
- [PR] Minor: Update supported image in docker_scan.yml [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2026/03/20 08:51:36 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20342) Kafka Clients performance degradation - posted by "Tomasz (Jira)" <ji...@apache.org> on 2026/03/20 09:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20343) Refactor makeCleaner test helper overloads in LogCleanerIntegrationTest to use the builder pattern - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/20 09:36:00 UTC, 0 replies.
- [PR] KAFKA-14487: Move LogManager to storage module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/20 09:43:37 UTC, 32 replies.
- Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/20 09:55:18 UTC, 0 replies.
- Re: [PR] MINOR: Update supported image in docker_scan.yml [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2026/03/20 10:18:19 UTC, 0 replies.
- [jira] [Created] (KAFKA-20344) upgrade jetty to 12.0.34 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/20 12:29:00 UTC, 0 replies.
- [PR] MINOR: Fix headers in KTableMapValues and KTableTransformValues [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/20 12:49:05 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/20 13:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20344) upgrade jetty to 12.0.34 - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/03/20 13:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/20 13:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20344) upgrade jetty to 12.0.34 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/20 13:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20344) upgrade jetty to 12.0.34 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/20 13:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/20 13:57:00 UTC, 4 replies.
- [PR] MINOR: mark flaky test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/20 14:00:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/20 14:17:00 UTC, 0 replies.
- [PR] removing boilerplate from header serializer test [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2026/03/20 15:14:17 UTC, 3 replies.
- [PR] MINOR: follow-up of KAFKA-20317 [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/20 15:47:48 UTC, 2 replies.
- [PR] MINOR: Fix default server config in BenchmarkConfigUtils [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/20 16:37:22 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-19937) Use the same reaper thread in Persister as well as NetworkPartitionMetadataClient - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/03/20 16:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/20 17:35:00 UTC, 0 replies.
- [PR] KAFKA-20335: Document KIP-1271 headers-aware state stores [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/20 17:35:08 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/20 17:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-20329: Test `headers` dsl.store.format further (1/N) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/03/20 18:38:03 UTC, 0 replies.
- [PR] KAFKA-20328 : Adding missing test files [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/20 19:28:52 UTC, 0 replies.
- [PR] KAFKA-19937: Introduced Shared ReaperThread for Persister / NetworkPartitionMetadataClient [kafka] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/03/20 20:26:38 UTC, 7 replies.
- Re: [PR] MINOR: Remove boilerplate code from header serializer test [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 21:18:26 UTC, 3 replies.
- Re: [PR] KAFKA-18652: Add `num.warmup.replicas` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/20 23:35:42 UTC, 1 replies.
- [PR] KAFKA-20343: Refactor LogCleanerLagIntegrationTest to use a builder for LogCleaner setup [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/03/21 00:49:04 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20343) Refactor makeCleaner test helper overloads in LogCleanerIntegrationTest to use the builder pattern - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/21 00:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20343) Refactor makeCleaner test helper overloads in LogCleanerIntegrationTest to use the builder pattern - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/21 00:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/03/21 01:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-20211, KAFKA-20345: Fix group coordinator background metrics test flake [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/21 02:48:44 UTC, 3 replies.
- [jira] [Created] (KAFKA-20346) LogCleaner#cleaners should be thread-safe - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/21 02:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20346) LogCleaner#cleaners should be thread-safe - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2026/03/21 03:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-20182 version updates: Gradle (9.2.1 -->> 9.4.1) and spotless plugin (8.0.0 -->> 8.4.0) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 03:47:44 UTC, 0 replies.
- Re: [PR] KAFKA-19881: change CVE scanner workflow to run on active branches (wip) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 04:11:34 UTC, 1 replies.
- [jira] [Commented] (KAFKA-18818) Significant delay in Metadata Update After Admin Client Operations in KRaft Mode - posted by "Erik van Oosten (Jira)" <ji...@apache.org> on 2026/03/21 08:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19811) Acked record on new topic not immediately visible to consumer - posted by "Erik van Oosten (Jira)" <ji...@apache.org> on 2026/03/21 08:16:00 UTC, 0 replies.
- [PR] KAFKA-20050: Add syntax highlighting for code blocks and commands [kafka] - posted by "gomudayya (via GitHub)" <gi...@apache.org> on 2026/03/21 08:36:58 UTC, 3 replies.
- [PR] MINOR: Fix potential NPE [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/21 10:28:17 UTC, 6 replies.
- [PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2026/03/21 11:41:57 UTC, 1 replies.
- [PR] Feat/mm2 fault tolerance [kafka] - posted by "rjain2778 (via GitHub)" <gi...@apache.org> on 2026/03/21 15:32:42 UTC, 1 replies.
- Re: [PR] KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/22 04:17:18 UTC, 1 replies.
- Re: [PR] KAFKA-19886 : Trogdor | Fix order of arguments in assertEquals in unit tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/22 04:17:20 UTC, 0 replies.
- Re: [PR] KAFKA-18896 add KIP-877 support for Login [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/22 04:25:14 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2026/03/22 09:41:00 UTC, 0 replies.
- [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2026/03/22 10:06:03 UTC, 13 replies.
- [PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/22 12:47:43 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20291) Implement assignment batching - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/03/22 13:28:00 UTC, 0 replies.
- [PR] KAFKA-20173: Propagate headers into serde 6/N [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/22 14:30:44 UTC, 1 replies.
- [jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/22 16:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/22 16:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-967) Use key range in ProducerPerformance - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/03/22 17:01:00 UTC, 0 replies.
- [PR] KAFKA-20173: Propagate headers into serde 7/N [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/03/22 19:27:03 UTC, 14 replies.
- [jira] [Created] (KAFKA-20347) Fix metric leak and JMX tag order in ShareCoordinatorMetrics - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/23 01:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20347) Fix metric leak and JMX tag order in ShareCoordinatorMetrics - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/23 01:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-19735: Add automatic commit offset caching in subscribe mode [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 04:18:34 UTC, 1 replies.
- Re: [PR] [KAFKA-16768] socketServer leaks accepted socketChannel instances due to race… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 04:18:40 UTC, 0 replies.
- Re: [PR] KAFKA-18608: feat: implement private_key_jwt client authentication for OAuth 2.0 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 04:18:43 UTC, 1 replies.
- [PR] CHG: Removing WindowedSerializer interface from public class implementations [kafka] - posted by "siddharthaDevineni (via GitHub)" <gi...@apache.org> on 2026/03/23 10:43:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17840) Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/23 11:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-17840) Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/23 11:52:00 UTC, 0 replies.
- [PR] KAFKA-19711: Add commit-rate metric to metered state stores Add commit metric [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/23 14:22:13 UTC, 12 replies.
- [jira] [Commented] (KAFKA-20144) Authority for LIST_CONFIG_RESOURCES should be dependent upon resource type - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/23 15:09:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20270) jetty-server vulnerability CVE-2026-1605 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/23 15:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20348) Move ControllerRegistrationManager to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/23 16:03:00 UTC, 0 replies.
- [PR] KAFKA-20348: Move ControllerRegistrationManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/23 16:03:43 UTC, 3 replies.
- [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/23 16:22:34 UTC, 30 replies.
- [jira] [Resolved] (KAFKA-19562) Rewrite AbortedTxn by generated protocol - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/23 17:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19851) Delete dynamic config that were removed by Kafka - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/03/23 19:36:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20349) Update zookeeper dependency to version 3.8.6 (CVE-2026-24308) - posted by "Martin Schwaiger (Jira)" <ji...@apache.org> on 2026/03/23 19:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20349) Update zookeeper dependency to version 3.8.6 (CVE-2026-24308) - posted by "Martin Schwaiger (Jira)" <ji...@apache.org> on 2026/03/23 19:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20349) Upgrade ZooKeeper to 3.8.6 - fix for CVE-2026-24308 - posted by "Martin Schwaiger (Jira)" <ji...@apache.org> on 2026/03/23 20:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 - posted by "Martin Schwaiger (Jira)" <ji...@apache.org> on 2026/03/23 20:10:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20348) Move ControllerRegistrationManager to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/23 20:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 - posted by "Martin Schwaiger (Jira)" <ji...@apache.org> on 2026/03/23 20:41:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/23 23:50:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/24 00:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20350) Consolidate and clarify boundaries of TestUtils classes across modules - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/24 00:19:00 UTC, 0 replies.
- [PR] KAFKA-20297: move ImplicitLinkedHash, ByteUtils from utils to internals [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/03/24 00:29:35 UTC, 8 replies.
- [jira] [Created] (KAFKA-20351) metrics leak caused by reducing `numRecoveryThreadsPerDataDir` in runtime - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/24 03:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20351) metrics leak caused by reducing `numRecoveryThreadsPerDataDir` in runtime - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/24 03:00:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20351) metrics leak caused by reducing `numRecoveryThreadsPerDataDir` in runtime - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2026/03/24 03:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-20216: Shadow Jetty dependencies to decouple from SLF4J version conflict [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 03:51:57 UTC, 2 replies.
- Re: [PR] KAFKA-19920 : Metadata | Fixed order of arguments of assertEquals in unit tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 04:17:20 UTC, 0 replies.
- Re: [PR] MINOR: Improve the CI to avoid running long time tests when only document is changed [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 04:17:23 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 - posted by "Yeojun Kim (Jira)" <ji...@apache.org> on 2026/03/24 04:23:00 UTC, 0 replies.
- [jira] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 - posted by "Yeojun Kim (Jira)" <ji...@apache.org> on 2026/03/24 04:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20323) Refactor test method to enable Mockito version upgrade - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/03/24 05:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/24 06:25:20 UTC, 2 replies.
- [PR] KAFKA-20323: Refactor deleteRecords stub to use partition-based matching for Mockito upgrade [kafka] - posted by "ChoMinGi (via GitHub)" <gi...@apache.org> on 2026/03/24 06:58:39 UTC, 1 replies.
- Re: [PR] KAFKA-20328 : Adding missing test files - streams headers [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/24 09:57:07 UTC, 4 replies.
- [PR] KAFKA-20349 Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 [kafka] - posted by "mjschwaiger (via GitHub)" <gi...@apache.org> on 2026/03/24 12:01:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20050) Add syntax highlighting for code blocks and commands in getting started - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/24 14:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20050) Add syntax highlighting for code blocks and commands in getting started - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/24 14:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20352) Update version in trunk docs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/24 14:36:00 UTC, 0 replies.
- [PR] KAFKA-18608: Add documentation for OAuth client assertion authentication (KIP-1258) [kafka] - posted by "prabhashkr (via GitHub)" <gi...@apache.org> on 2026/03/24 14:40:42 UTC, 2 replies.
- [jira] [Commented] (KAFKA-18608) Enhancing Apache Kafka OAuth2 Authentication: Adding Support for private_key_jwt Client Assertion - posted by "Prabhash Kumar (Jira)" <ji...@apache.org> on 2026/03/24 14:42:00 UTC, 0 replies.
- [PR] MINOR: Test Coverage for Segmented stores [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2026/03/24 16:37:57 UTC, 5 replies.
- [PR] KAFKA-20340: Remove GroupConfigManager dependency from SharePartition [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/24 17:39:37 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20050) Add syntax highlighting for code blocks and commands in getting started - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/24 17:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] few methods show `java.lang.Exception: bad stuff` (altough Gradle build yields `BUILD SUCCESSFUL` result) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/24 21:45:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] few methods shows `java.lang.Exception: bad stuff` (altough Gradle build shows `BUILD SUCCESSFUL` result) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/24 21:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] some test methods show `java.lang.Exception: bad stuff` error (altough Gradle build yields `BUILD SUCCESSFUL` result) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/24 21:48:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] some test methods show `java.lang.Exception: bad stuff` error (although Gradle build yields `BUILD SUCCESSFUL` result) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/24 21:55:00 UTC, 5 replies.
- [PR] Started on work [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/24 22:20:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] some test methods show `java.lang.Exception: bad stuff` error (although Gradle build yields `BUILD SUCCESSFUL` result) - posted by "Yeojun Kim (Jira)" <ji...@apache.org> on 2026/03/25 00:45:00 UTC, 0 replies.
- [PR] feat: Upgrade RocksDB to 10.5.1 and deprecate options that are remove… [kafka] - posted by "deepgolani4 (via GitHub)" <gi...@apache.org> on 2026/03/25 02:58:32 UTC, 0 replies.
- Re: [PR] KAFKA-20245: DLQ non-delivery related records. [2/N] [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 03:53:01 UTC, 0 replies.
- Re: [PR] KAFKA-20253: Fix high CPU spin loop after failed SASL re-authentication [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 03:53:04 UTC, 0 replies.
- [PR] KAFKA-19651: Restore thread interrupted status in consumer close() [kafka] - posted by "daguimu (via GitHub)" <gi...@apache.org> on 2026/03/25 03:58:55 UTC, 0 replies.
- Re: [PR] KAFKA-19408 : Add check for compression type mismatch for push telemetry requests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 04:17:32 UTC, 1 replies.
- Re: [PR] KAFKA-19443: test-common ClusterInstance should make it easy to have more listeners [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 04:17:33 UTC, 0 replies.
- Re: [PR] KAFKA-19674 - Disallow create too many partitions in ZK mode [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 04:17:36 UTC, 0 replies.
- Re: [PR] KAFKA-19998: KRaft client should expose the latest committed kraft version for some readers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 04:17:43 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 06:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 06:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19611) Enable ProducerPerformance to abort transaction randomly - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 06:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19414) Remove Public APIs from 4.1 - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 07:28:00 UTC, 0 replies.
- [jira] (KAFKA-19414) Remove Public APIs from 4.1 - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 07:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15079) Offset expirations in topics with less event generation results in messages that take months to be delivered. - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 07:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19611) Enable ProducerPerformance to abort transaction randomly - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/25 07:43:00 UTC, 1 replies.
- [PR] Add transaction abort rate to producer perf [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/03/25 07:49:48 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20354) Control Batches documentation only mentions abort and commit - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/03/25 07:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20354) Control Batches documentation only mentions abort and commit - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/03/25 07:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20354) Add missing Control Batch types in documentation - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/03/25 08:31:00 UTC, 2 replies.
- [PR] KAFKA-20354: Add missing Control Batch types in documentation [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/03/25 08:32:03 UTC, 3 replies.
- [jira] [Created] (KAFKA-20355) Invalid formatting of System Properties in website - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/25 10:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20355) Invalid formatting of System Properties in website - posted by "gomudayya (Jira)" <ji...@apache.org> on 2026/03/25 12:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20355) Invalid formatting of System Properties in website - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/25 12:19:00 UTC, 0 replies.
- [PR] MINOR: Fix flaky test `CoordinatorBackgroundThreadPoolExecutorTest` [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/25 12:26:36 UTC, 3 replies.
- [PR] KAFKA-20302: Receive buffers allocated from MemoryPool may not be rel… [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2026/03/25 13:12:05 UTC, 8 replies.
- [jira] [Commented] (KAFKA-19638) NPE in `Processor#init()` accessing state store - posted by "Ray McDermott (Jira)" <ji...@apache.org> on 2026/03/25 13:29:00 UTC, 5 replies.
- [jira] [Reopened] (KAFKA-19638) NPE in `Processor#init()` accessing state store - posted by "Ray McDermott (Jira)" <ji...@apache.org> on 2026/03/25 13:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20356) Make cluster id in-memory threadsafe - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/25 14:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to something newer - posted by "Deep Golani (Jira)" <ji...@apache.org> on 2026/03/25 14:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-15630: Improve documentation of offset.lag.max [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/25 16:21:52 UTC, 4 replies.
- [PR] Remove explicit flushes from RocksDBStores [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2026/03/25 17:13:03 UTC, 0 replies.
- Re: [PR] KAFKA-20349: Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/25 18:19:53 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19711) commit-rate metric - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/25 18:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19711) commit-rate metric - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/25 18:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-17411) StateStore managed changelog offsets - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/25 18:33:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20340) SharePartition should keep only one config reference - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/25 19:05:00 UTC, 0 replies.
- [PR] MINOR: Enable dependabot for github-actions [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/25 19:53:40 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20353) [ShareCoordinatorServiceTest in trunk] some test methods show `java.lang.Exception: bad stuff` error (although Gradle build yields `BUILD SUCCESSFUL` result) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/03/25 19:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/25 20:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/25 20:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/25 20:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/25 20:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/25 20:57:00 UTC, 0 replies.
- [PR] MINOR: tidy up SocketServerMemoryPoolTest [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2026/03/26 02:42:48 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 02:51:00 UTC, 0 replies.
- Re: [PR] Enhance MirrorMaker2 with fault tolerance for log truncation and topic reset [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 04:01:43 UTC, 0 replies.
- Re: [PR] Add support to set the target timezone when we use the TimestampConverter. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 04:19:27 UTC, 1 replies.
- Re: [PR] MINOR: Backport fix for test_fencing_static_consumer system test to 3.9 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 04:19:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20193) Remove `static T value(...)` method from ValueTimestampHeadersDeserializer if not needed - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/26 10:18:00 UTC, 4 replies.
- [PR] Bump requests from 2.32.3 to 2.33.0 in /.github/scripts [kafka-merge-queue-sandbox] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 11:51:09 UTC, 0 replies.
- Re: [PR] Bump requests from 2.32.3 to 2.32.4 in /.github/scripts [kafka-merge-queue-sandbox] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 11:51:11 UTC, 1 replies.
- [PR] KAFKA-20355: Invalid formatting of System Properties in website [kafka] - posted by "gomudayya (via GitHub)" <gi...@apache.org> on 2026/03/26 13:20:59 UTC, 4 replies.
- [jira] [Created] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/26 13:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/26 13:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/26 13:29:00 UTC, 0 replies.
- [PR] Bump requests from 2.32.4 to 2.33.0 in /.github/scripts [kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 13:36:22 UTC, 1 replies.
- [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in group-coordinator and part of clients [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/03/26 13:39:20 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20355) Invalid formatting of System Properties in website - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/26 14:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20358) Allow KTable/KStream and GlobalKTable on same topic - posted by "Stef Noten (Jira)" <ji...@apache.org> on 2026/03/26 15:41:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/26 15:42:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20358) Allow KTable/KStream and GlobalKTable on same topic - posted by "Stef Noten (Jira)" <ji...@apache.org> on 2026/03/26 15:42:03 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-19992) Allow to configure max memory for restore path - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/26 15:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20359) Consider using `docker.io/library/eclipse-temurin:21-jdk-jammy` instead - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 15:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20359) Consider using `docker.io/library/eclipse-temurin:21-jdk-jammy` instead - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/03/26 15:49:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20360) Upgrade ducktape from 0.13 to 0.14 and requests from 2.32.2 to 2.32.4 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 15:50:00 UTC, 0 replies.
- [PR] KAFKA-20359 : Update docker image with fully qualified name [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/26 15:54:13 UTC, 6 replies.
- [jira] [Commented] (KAFKA-20359) Consider using `docker.io/library/eclipse-temurin:21-jdk-jammy` instead - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/26 15:55:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20360) Upgrade ducktape from 0.13 to 0.14 and requests from 2.32.2 to 2.32.4 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/26 15:58:00 UTC, 0 replies.
- [PR] KAFKA-20360 : Upgrade ducktape and requests [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/26 16:01:21 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20193) Remove `static T value(...)` method from ValueTimestampHeadersDeserializer if not needed - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/26 16:03:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20361) Fix LazyDownConversionRecordsTest in using zlib-ng - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 16:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20361) Fix LazyDownConversionRecordsTest in using zlib-ng - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 16:16:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/26 16:42:00 UTC, 0 replies.
- [PR] KAFKA-9195: Use Randomized State Directory Names in Streams System Tests [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/26 16:43:21 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/03/26 17:04:00 UTC, 0 replies.
- [PR] KAFKA-6786: Remove additional configs in StreamsBrokerDownResilienceTest [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/03/26 17:27:21 UTC, 0 replies.
- Re: [PR] KAFKA-19541; Allow configuration of kraft RPC max bytes [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/26 21:00:49 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19638) NPE in `Processor#init()` accessing state store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/26 21:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20358) Allow KTable/KStream and GlobalKTable on same topic - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/26 21:18:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20361) Fix LazyDownConversionRecordsTest in using zlib-ng - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/26 21:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20358) Allow KTable/KStream and GlobalKTable on same topic - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/26 21:21:00 UTC, 0 replies.
- [PR] Fix LazyDownConversionRecordsTest in using zlib-ng [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/26 21:37:16 UTC, 0 replies.
- Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/26 21:41:01 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-20360) Upgrade ducktape from 0.13 to 0.14 and requests from 2.32.2 to 2.32.4 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 21:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/26 23:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20363) flaky testIdleTimeCallback - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/27 00:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/27 00:55:00 UTC, 6 replies.
- Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/27 02:47:38 UTC, 1 replies.
- Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 04:02:03 UTC, 1 replies.
- [PR] KAFKA-18972: Use custom processor during read-only state store restoration [kafka] - posted by "daguimu (via GitHub)" <gi...@apache.org> on 2026/03/27 04:55:36 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20363) flaky testIdleTimeCallback - posted by "Yeojun Kim (Jira)" <ji...@apache.org> on 2026/03/27 06:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20267) Move LogCleanerParameterizedIntegrationTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/27 09:54:00 UTC, 0 replies.
- [PR] MINOR: Various cleanups in raft module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/27 10:38:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-20364) Remove control records reads from metadata module - posted by "John Mannooparambil (Jira)" <ji...@apache.org> on 2026/03/27 12:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20364) Remove control records reads from metadata module - posted by "John Mannooparambil (Jira)" <ji...@apache.org> on 2026/03/27 13:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/27 15:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/27 15:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20358) Allow KTable/KStream and GlobalKTable on same topic - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/27 17:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17120) Race condition in KafkaStreams.close can result in StreamsException "Failed to shut down while in state" - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/27 18:11:00 UTC, 0 replies.
- Re: [PR] KAFKA-16600: Add unit test for idempotent PENDING_SHUTDOWN state transition [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/27 18:11:15 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19541) KRaft should handle snapshot fetches under slow networks - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/03/27 19:04:00 UTC, 0 replies.
- [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2026/03/27 20:42:41 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/27 22:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20287) Verify (and potentially fix) if all CF handles (and other objects) are closed correctly - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/27 22:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/27 23:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/03/27 23:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/28 00:05:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16600) Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/03/28 00:37:00 UTC, 0 replies.
- Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 04:17:21 UTC, 1 replies.
- Re: [PR] KAFKA-19688: add new KStreams.process() overlaod [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 04:17:29 UTC, 1 replies.
- [jira] [Created] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/03/28 04:41:00 UTC, 0 replies.
- [PR] KAFKA-20347: Fix metric leak and JMX tag order in ShareCoordinatorMetrics [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/03/28 05:05:35 UTC, 2 replies.
- [jira] [Created] (KAFKA-20366) Add syntax highlighting across documentation pages - posted by "gomudayya (Jira)" <ji...@apache.org> on 2026/03/28 05:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20366) Add syntax highlighting across documentation pages - posted by "gomudayya (Jira)" <ji...@apache.org> on 2026/03/28 05:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20366) Add syntax highlighting across documentation pages - posted by "gomudayya (Jira)" <ji...@apache.org> on 2026/03/28 05:59:00 UTC, 0 replies.
- [PR] KAFKA-20205: Use utils in TimestampedToHeadersWindowStoreAdapter [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/28 07:15:53 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/03/28 07:20:00 UTC, 0 replies.
- [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka] - posted by "gomudayya (via GitHub)" <gi...@apache.org> on 2026/03/28 08:26:30 UTC, 5 replies.
- [jira] [Commented] (KAFKA-19469) Dead-letter queues for share groups - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/28 09:12:00 UTC, 0 replies.
- [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka] - posted by "zendy199x (via GitHub)" <gi...@apache.org> on 2026/03/28 17:29:19 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2026/03/28 17:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20367) Support Share Groups (Queue Semantics) in Kafka Connect Sink Connectors - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/28 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20367) Support Share Groups (Queue Semantics) in Kafka Connect Sink Connectors - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/28 20:42:00 UTC, 0 replies.
- [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka] - posted by "sstremler (via GitHub)" <gi...@apache.org> on 2026/03/29 01:45:55 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19958) Race condition between OAuthBearerSaslClientCallbackHandler and ExpiringCredentialRefreshingLogin.reLogin - posted by "luman (Jira)" <ji...@apache.org> on 2026/03/29 05:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/03/29 11:58:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/03/29 12:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20216) Jetty 12 requires slf4j 2 - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/03/29 13:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14487) Move LogManager to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/29 13:56:00 UTC, 0 replies.
- [PR] MINOR: Move TerseFailure to server-common [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/03/29 14:21:32 UTC, 5 replies.
- [PR] MINOR: Use getAbsolutePath in LocalLog#exception [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/29 14:38:10 UTC, 1 replies.
- [PR] KAFKA-10357: Add explicit internal topic initialization for Kafka Str… [kafka] - posted by "k-apol (via GitHub)" <gi...@apache.org> on 2026/03/29 21:20:15 UTC, 0 replies.
- [PR] HOTFIX: Fix spotless in SocketServerMemoryPoolTest [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/30 00:52:17 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20359) Consider using `docker.io/library/eclipse-temurin:21-jdk-jammy` instead - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 01:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20359) Consider using `docker.io/library/eclipse-temurin:21-jdk-jammy` instead - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 01:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20368) Use LinkedHashMap for deterministic metric tags order in RLMExpirationTask - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 01:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20347) Fix metric leak and JMX tag order in ShareCoordinatorMetrics - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 02:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20368) Use LinkedHashMap for deterministic metric tags order in RLMExpirationTask - posted by "Chia-Yi Chiu (Jira)" <ji...@apache.org> on 2026/03/30 02:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20369) Upgrade log4j2 from 2.25.3 to 2.25.4 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 02:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20369) Upgrade log4j2 from 2.25.3 to 2.25.4 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 02:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20219) Override `getPosition` correctly for TimestampedKeyValueStoreWithHeaders - posted by "Guang Zhao (Jira)" <ji...@apache.org> on 2026/03/30 02:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20370) BrokerRegistrationState per-broker metric not registered after snapshot load - posted by "Matt Venz (Jira)" <ji...@apache.org> on 2026/03/30 02:26:00 UTC, 0 replies.
- Re: [PR] KAFKA-20015: Stop sending timed out fetch requests from ShareConsumeRequestManager. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 04:29:25 UTC, 0 replies.
- [jira] [Created] (KAFKA-20371) Add Iterable constructor to generated message collections - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/30 09:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20371) Add Iterable constructor to generated message collections - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/03/30 09:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20333) Flaky runCloseClassicConsumerMultiConsumerSessionTimeoutTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/30 10:45:00 UTC, 0 replies.
- [PR] KAFKA-20371: Add Iterable constructor to generated message collections [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/30 11:45:45 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20330) Share partition leader restart without leadership change gives wrong exception - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/30 12:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20372) Flaky NamedTopologyIntegrationTest shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/30 12:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20372) Flaky NamedTopologyIntegrationTest shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/30 12:34:00 UTC, 2 replies.
- [PR] MINOR: Improve shutdown logging for share consumer system tests [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/30 12:57:54 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20372) Flaky NamedTopologyIntegrationTest shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/30 13:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics - posted by "Nick Guo (Jira)" <ji...@apache.org> on 2026/03/30 14:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20066) Implement KIP-1251: Assignment epochs for consumer groups - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/03/30 14:13:00 UTC, 0 replies.
- [PR] KAFKA-20369 - Upgrade log4j2 to 2.25.4 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/30 14:20:25 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20369) Upgrade log4j2 from 2.25.3 to 2.25.4 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/30 14:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20373) CVE-2025-67030 in plexus-utils-3.5.1.jar - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/30 15:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-20297: move ImplicitLinkedHashCollection, ImplicitLinkedHashMultiCollection, and ByteUtils from utils to internals [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/03/30 15:57:51 UTC, 1 replies.
- Re: [PR] KAFKA-19851; Delete dynamic configs that were removed by Kafka [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/03/30 16:00:23 UTC, 0 replies.
- [PR] KAKFA-20332: Fix to ensure app thread not collecting records for partitions being revoked [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/30 16:10:31 UTC, 0 replies.
- Re: [PR] KAFKA-20246: Detection and handling of misrouted connections [1/N] [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2026/03/30 17:46:25 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20373) CVE-2025-67030 in plexus-utils-3.5.1.jar - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/30 19:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20373) CVE-2025-67030 in plexus-utils-3.5.1.jar - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/30 19:09:00 UTC, 3 replies.
- Re: [PR] MINOR:Remove explicit flushes from RocksDBStores [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/03/30 19:36:15 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-19851) Delete dynamic config that were removed by Kafka - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/03/30 20:09:00 UTC, 0 replies.
- [PR] KAFKA-20282: Add message to classic consumer startup guiding to next-gen protocol [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/30 21:53:22 UTC, 4 replies.
- [jira] [Updated] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3 - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2026/03/30 22:06:00 UTC, 2 replies.
- [jira] [Reopened] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3 - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2026/03/30 22:06:00 UTC, 0 replies.
- [PR] Revert 2PC public API changes [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2026/03/30 23:55:25 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20350) Consolidate and clarify boundaries of TestUtils classes across modules - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2026/03/31 00:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20316) Rewrite AddPartitionsTest with ClusterInstance - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2026/03/31 01:04:00 UTC, 0 replies.
- [PR] KAFKA-20316: Rewrite AddPartitionsTest with ClusterInstance [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2026/03/31 01:57:39 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20370) BrokerRegistrationState per-broker metric not registered after snapshot load - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/03/31 03:33:00 UTC, 0 replies.
- Re: [PR] WIP: Removing WindowedSerializer interface from public class implementations [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 04:01:47 UTC, 0 replies.
- Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 04:21:55 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20036) Handle LogCleaner segment overflow caused by compression level changes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/31 05:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20036) Handle LogCleaner segment overflow caused by compression level changes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/31 05:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20374) DescribeConfigs should show DEFAULT_CONFIG synonym for topic configs without broker synonym - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/31 06:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20374) DescribeConfigs should show DEFAULT_CONFIG synonym for topic configs without broker synonym - posted by "majialong (Jira)" <ji...@apache.org> on 2026/03/31 06:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/03/31 06:58:00 UTC, 0 replies.
- [PR] KAFKA-20194: Ensure backward compatiblity [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/31 07:26:30 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20336) Update docs - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 07:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 07:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20316) Rewrite AddPartitionsTest with ClusterInstance - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/31 08:26:00 UTC, 0 replies.
- [PR] KAFKA-20336: Add documentation for KIP-1285 DSL headers-aware state s… [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/03/31 08:36:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20336) Update docs - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 08:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19958) Race condition between OAuthBearerSaslClientCallbackHandler and ExpiringCredentialRefreshingLogin.reLogin - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 08:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18965) Improve release validation for kafka-clients - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 09:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15370) Support Participation in 2PC (KIP-939) - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 09:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20375) Unify method signature for retrieving config names across config classes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/31 09:22:00 UTC, 0 replies.
- [PR] KAFKA-20259: Verify IQv1 and IQv2 do not break with headers-aware state stores [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/03/31 09:26:27 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20373) CVE-2025-67030 in plexus-utils-3.5.1.jar - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/03/31 09:30:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20375) Unify method signature for retrieving config names across config classes - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2026/03/31 09:37:00 UTC, 0 replies.
- [PR] KAFKA-20078: Fix DumpLogSegments to return proper exit codes [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/03/31 09:43:12 UTC, 0 replies.
- [PR] MINOR: Sort reviewer candidates by contribution count [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/03/31 09:48:41 UTC, 5 replies.
- [PR] [POC] KAFKA-20171: Kafka Streams use topic ids. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/03/31 10:16:51 UTC, 0 replies.
- [PR] Cp 4.2.1 [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/03/31 10:52:22 UTC, 0 replies.
- [PR] KAFKA-20373 [kafka] - posted by "averemee-si (via GitHub)" <gi...@apache.org> on 2026/03/31 12:30:17 UTC, 0 replies.
- Re: [PR] KAFKA-20332: Fix to ensure app thread not collecting records for partitions being revoked [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/31 12:33:45 UTC, 1 replies.
- [jira] [Created] (KAFKA-20376) Update site docs for rebalance protocol page - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/31 13:01:00 UTC, 0 replies.
- Re: [PR] MINOR: Cherry pick important fixes for 4.2.1 [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/03/31 13:23:13 UTC, 0 replies.
- [PR] KAFKA-20297: move testIncrement and testIncrementUpperBoundary to ByteUtilsTest [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/03/31 13:29:10 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20376) Update site docs for rebalance protocol page - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/31 13:35:00 UTC, 2 replies.
- [PR] KAFKA-20094: Add sanity test coverage for default configuration (no environment variables) [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/31 14:02:13 UTC, 0 replies.
- [PR] KAFKA 18965 release validation kafka clients [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/03/31 14:08:41 UTC, 0 replies.
- [PR] MINOR: Cleanups in LogManager [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/03/31 14:20:53 UTC, 1 replies.
- [jira] [Created] (KAFKA-20377) ducker-ak does not support passing additional Docker build arguments - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/31 14:26:00 UTC, 0 replies.
- [PR] MINOR: Add todo to WindowSegmentWithHeaders [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/03/31 14:43:14 UTC, 0 replies.
- [jira] [Created] (KAFKA-20378) ducker-ak container memory limit is hardcoded - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/31 14:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/03/31 14:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners for kraft.version=0 - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/31 14:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20361) Fix LazyDownConversionRecordsTest in using zlib-ng - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/03/31 14:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20381) Producer Transaction Session Heartbeat - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 15:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20381) Producer Transaction Session Heartbeat - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/03/31 15:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17789) State updater stuck when starting with empty state folder - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/03/31 15:15:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20381) Producer Transaction Session Heartbeat - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/03/31 15:19:00 UTC, 4 replies.
- Re: [PR] KAFKA-20194: Ensure backward compatibility [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/31 15:56:11 UTC, 4 replies.
- [PR] KAFKA-20380: kraft.version=0 leaders should advertise their endpoint from controller.quorum.voters [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/03/31 16:12:53 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-13499) Avoid restoring outdated records - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/03/31 17:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14487) Move LogManager to storage module - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2026/03/31 18:30:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-14487) Move LogManager to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/03/31 18:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13499) Avoid restoring outdated records - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/03/31 19:30:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20382) Improve interrupts handling when updating assignment for callbacks - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/03/31 19:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners if the latter is not defined - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/31 20:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/31 20:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20383) BrokerServerMetrics should not rely on leaked state from MetadataLoader - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/31 20:14:00 UTC, 0 replies.
- [PR] KAFKA-20382: Send background error when updating assignment for callbacks fail [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/03/31 20:15:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20384) Per-Record Context Processing for Kafka Consumers - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 20:40:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20384) Per-Record Context Processing for Kafka Consumers - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 20:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20385) RebalanceHandler: Consumer-Aware Rebalance Callback - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 20:43:00 UTC, 0 replies.
- [PR] KAFKA-20363 : Fix flaky testIdleTimeCallback in KafkaEventQueueTest [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/03/31 21:02:12 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20363) flaky testIdleTimeCallback - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/03/31 21:03:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20385) RebalanceHandler: Consumer-Aware Rebalance Callback - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 21:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20386) SerDe and Interceptor Metrics - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 21:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20386) SerDe and Interceptor Metrics - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 21:51:00 UTC, 0 replies.
- [PR] MINOR: deprecate internal config for NamedTopologies [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/31 22:19:25 UTC, 0 replies.
- [jira] [Created] (KAFKA-20387) Extend RecordHeader API for Common Value Types - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 22:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20387) Extend RecordHeader API for Common Value Types - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/03/31 22:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20338) Add benchmarking support to RaftClientTestContext - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/03/31 22:54:00 UTC, 0 replies.
- Re: [PR] MINOR: Improve ValueTimestampHeader Serdes [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/03/31 23:48:37 UTC, 1 replies.