dev  

Messages by Date

• 2026/06/18 Re: Automation for zookeeper to kraft migration. Ghai, Varun via dev
• 2026/06/18 Re: [DISCUSS] KIP-1279: Cluster Mirroring Federico Valeri
• 2026/06/18 [jira] [Resolved] (KAFKA-20714) Refactor KRaft API around message handling Jira
• 2026/06/18 Re: [VOTE] 4.3.1 rc2 Matthias J. Sax
• 2026/06/18 Re: [DISCUSS] KIP-1347: Overriding voter set on storage formatting José Armando García Sancio via dev
• 2026/06/18 [jira] [Created] (KAFKA-20714) Refactor KRaft API around message handling Jira
• 2026/06/18 Re: [DISCUSS] KIP-1359: Improve usability of resetting group offsets 黃竣陽
• 2026/06/18 Re: [DISCUSS] KIP-1359: Improve usability of resetting group offsets Chia-Ping Tsai
• 2026/06/18 [jira] [Resolved] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService Lucas Brutschy (Jira)
• 2026/06/18 Re: Automation for zookeeper to kraft migration. Paolo Patierno
• 2026/06/18 Re: [VOTE] 4.3.1 rc2 Rich Bowen
• 2026/06/18 [jira] [Created] (KAFKA-20713) Review level for client-side log on fetch session evicted Lianet Magrans (Jira)
• 2026/06/18 [jira] [Resolved] (KAFKA-19404) Connect's plugin.path documentation does not match behavior Mickael Maison (Jira)
• 2026/06/18 [jira] [Resolved] (KAFKA-20009) Top level pages should include short descriptions for each section Mickael Maison (Jira)
• 2026/06/18 [jira] [Resolved] (KAFKA-20541) Duplicate generated folder in kafka-site Mickael Maison (Jira)
• 2026/06/18 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/18 [jira] [Created] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name Federico Valeri (Jira)
• 2026/06/18 Re: [DISCUSS] KIP-1279: Cluster Mirroring Federico Valeri
• 2026/06/18 [jira] [Created] (KAFKA-20711) Streams task restore-remaining-records metric invalid under EOS Nicholas Telford (Jira)
• 2026/06/17 RE: Re: [DISCUSS] KIP-1333: Support log segments larger than 2 GB Haifeng Chen
• 2026/06/17 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Andrew Schofield
• 2026/06/17 [VOTE] 4.3.1 rc2 Bill Bejeck
• 2026/06/17 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Alieh Saeedi via dev
• 2026/06/17 Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #216 Apache Jenkins Server
• 2026/06/17 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/17 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Jun Rao via dev
• 2026/06/17 Re: [VOTE] 4.3.1 rc1 Bill Bejeck
• 2026/06/17 Re: [VOTE] 4.3.1 rc1 Rich Bowen
• 2026/06/17 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
• 2026/06/17 Re: [VOTE] KIP-1332: Dynamic memory allocation for the Kafka producer Frank Chi via dev
• 2026/06/17 [jira] [Created] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable Shekhar Prasad Rajak (Jira)
• 2026/06/17 Re: Automation for zookeeper to kraft migration. Anton Agestam via dev
• 2026/06/17 Re: [PR] KAFKA-20049: Publish Hugo base image under Apache namespace [kafka-site] via GitHub
• 2026/06/17 Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.2 [kafka-site] via GitHub
• 2026/06/17 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/17 Automation for zookeeper to kraft migration. Kaushik Srinivas (Nokia) via dev
• 2026/06/16 Re: [VOTE] 4.3.1 rc1 Matthias J. Sax
• 2026/06/16 [DISCUSS] KIP-1359: Improve usability of resetting group offsets Andrew Schofield
• 2026/06/16 [jira] [Created] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers kravii (Jira)
• 2026/06/16 Re: [DISCUSS] KIP-1318: Model Context Protocol (MCP) Server for Apache Kafka vaquar khan
• 2026/06/16 Re: [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
• 2026/06/16 Re: [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
• 2026/06/16 [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
• 2026/06/16 [jira] [Resolved] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted Lianet Magrans (Jira)
• 2026/06/16 [jira] [Resolved] (KAFKA-20522) Refine test coverage for consumer close-on-interrupt best-effort behavior Lianet Magrans (Jira)
• 2026/06/16 [DISCUSS] KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen
• 2026/06/16 KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen
• 2026/06/16 [jira] [Created] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen (Jira)
• 2026/06/16 Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sébastien Viale
• 2026/06/16 Re: [VOTE] KIP-1332: Dynamic memory allocation for the Kafka producer Andrew Schofield
• 2026/06/16 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Matthias J. Sax
• 2026/06/16 [jira] [Resolved] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer Jheng-Sing Chen (Jira)
• 2026/06/16 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Chia-Ping Tsai
• 2026/06/16 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
• 2026/06/16 [jira] [Created] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders) Jess Jin (Jira)
• 2026/06/16 [jira] [Created] (KAFKA-20701) KIP drafting, publication, discussion, vote Jess Jin (Jira)
• 2026/06/16 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/16 [jira] [Created] (KAFKA-20700) AllowedPaths should resolve symlinks before validating paths against allowed.paths Nilesh Kumar (Jira)
• 2026/06/16 [VOTE] KIP-1332: Dynamic memory allocation for the Kafka producer Lianet Magrans
• 2026/06/16 [jira] [Created] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context Jira
• 2026/06/16 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Alieh Saeedi via dev
• 2026/06/16 Re: [DISCUSS] KIP-1326: Include broker static configurations in BrokerRegistrationRequest Omnia Ibrahim
• 2026/06/16 [jira] [Resolved] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing Andrew Schofield (Jira)
• 2026/06/16 Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Lucas Brutschy via dev
• 2026/06/16 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Andrew Schofield
• 2026/06/15 Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Ashwin via dev
• 2026/06/15 [VOTE] 4.3.1 rc1 Bill Bejeck
• 2026/06/15 [jira] [Created] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor Evan Zhou (Jira)
• 2026/06/15 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Chia-Ping Tsai
• 2026/06/15 Re: [DISCUSS] KIP-1332: Dynamic memory allocation for the Kafka producer Jun Rao via dev
• 2026/06/15 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Jun Rao via dev
• 2026/06/15 Re: [DISCUSS] KIP-1332: Dynamic memory allocation for the Kafka producer Lianet Magrans
• 2026/06/15 Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
• 2026/06/15 Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
• 2026/06/15 [PR] Bump hugo-extended from 0.161.1 to 0.163.2 [kafka-site] via GitHub
• 2026/06/15 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/15 [jira] [Created] (KAFKA-20697) Add cross-version system tests Matthias J. Sax (Jira)
• 2026/06/15 Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Andrew Schofield
• 2026/06/15 Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Matthias J. Sax
• 2026/06/15 Re: [DISCUSS] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Matthias J. Sax
• 2026/06/15 Re: [DISCUSS] KIP-1332: Dynamic memory allocation for the Kafka producer Jun Rao via dev
• 2026/06/15 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Jun Rao via dev
• 2026/06/15 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Chia-Ping Tsai
• 2026/06/15 Re: 回复： [DISCUSS] KIP-1134: Virtual Clusters in Kafka Andrew Schofield
• 2026/06/15 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Jun Rao via dev
• 2026/06/15 [jira] [Created] (KAFKA-20696) Periodic plugin.deleteTopology cleanup for naturally-expired streams groups TengYao Chi (Jira)
• 2026/06/15 [jira] [Created] (KAFKA-20695) Extend "describe group" to return "task offset" metadata Matthias J. Sax (Jira)
• 2026/06/15 Re: [PR] MINOR: Update KAFKA-20254 migration bug note — fix now available in 4.2.1 [kafka-site] via GitHub
• 2026/06/15 [jira] [Resolved] (KAFKA-20637) Move ForwardingManager to server module Mickael Maison (Jira)
• 2026/06/15 [PR] MINOR: Update KAFKA-20254 migration bug note — fix now available in 4.2.1 [kafka-site] via GitHub
• 2026/06/15 [jira] [Created] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing Shekhar Prasad Rajak (Jira)
• 2026/06/15 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Lucas Brutschy via dev
• 2026/06/15 Re: [DISCUSS] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sébastien Viale
• 2026/06/15 [jira] [Created] (KAFKA-20693) NPE in error handling in AbstractHerder Gaetan Collaud (Jira)
• 2026/06/15 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/15 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/15 [jira] [Resolved] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families Bill Bejeck (Jira)
• 2026/06/15 [PR] Add back negation that was lost in rewrite [kafka-site] via GitHub
• 2026/06/15 [jira] [Created] (KAFKA-20692) Add unit tests for ToolsUtils Deepak Kumar S S (Jira)
• 2026/06/15 Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
• 2026/06/15 [jira] [Resolved] (KAFKA-20613) Copy original record data in DLQ records Apoorv Mittal (Jira)
• 2026/06/15 Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Andrew Schofield
• 2026/06/15 [jira] [Resolved] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases Andrew Schofield (Jira)
• 2026/06/14 Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Matthias J. Sax
• 2026/06/14 Re: [DISCUSS] KIP-1326: Include broker static configurations in BrokerRegistrationRequest Luke Chen
• 2026/06/14 [jira] [Created] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n²) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line Shekhar Prasad Rajak (Jira)
• 2026/06/14 [jira] [Created] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases Shekhar Prasad Rajak (Jira)
• 2026/06/14 Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
• 2026/06/14 [jira] [Created] (KAFKA-20689) Remove unnecessary Hamcrest dependency from tools module Jheng-Sing Chen (Jira)
• 2026/06/14 Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups Muralidhar Basani via dev
• 2026/06/13 Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Manikumar
• 2026/06/13 [jira] [Resolved] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start Chia-Ping Tsai (Jira)
• 2026/06/13 [jira] [Resolved] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var Maros Orsak (Jira)
• 2026/06/13 [jira] [Resolved] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step Maros Orsak (Jira)
• 2026/06/13 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
• 2026/06/12 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Chia-Ping Tsai
• 2026/06/12 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Jun Rao via dev
• 2026/06/12 [jira] [Created] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families Lucy Liu (Jira)
• 2026/06/12 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/12 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Andrew Schofield
• 2026/06/12 Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
• 2026/06/12 Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
• 2026/06/12 [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
• 2026/06/12 Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Gabriella Fu via dev
• 2026/06/12 Re: [DISCUSS] KIP-1332: Dynamic memory allocation for the Kafka producer Lianet Magrans
• 2026/06/12 Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Matthias J. Sax
• 2026/06/12 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Bill Bejeck
• 2026/06/12 [jira] [Created] (KAFKA-20687) Consider improving unused chunks reuse when no data written Lianet Magrans (Jira)
• 2026/06/12 Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups David Jacot
• 2026/06/12 Kafka Streams EOS: checkpoint file persists through RUNNING and skips the state wipe after unclean crash (4.1.2) esiva
• 2026/06/12 Re: Kafka Streams EOS: checkpoint file persists through RUNNING and skips the state wipe after unclean crash (4.1.2) esiva
• 2026/06/12 [jira] [Resolved] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled David Jacot (Jira)
• 2026/06/12 Re: [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
• 2026/06/12 Re: [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Alieh Saeedi via dev
• 2026/06/12 [jira] [Reopened] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids Luke Chen (Jira)
• 2026/06/12 [jira] [Resolved] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids Luke Chen (Jira)
• 2026/06/11 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Jun Rao via dev
• 2026/06/11 Re: [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Matthias J. Sax
• 2026/06/11 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Matthias J. Sax
• 2026/06/11 Subject: [VOTE] 4.3.1 RC0 Bill Bejeck
• 2026/06/11 Re: [DISCUSS] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Matthias J. Sax
• 2026/06/11 Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.9 #278 Apache Jenkins Server
• 2026/06/11 Re: [DISCUSS] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sébastien Viale
• 2026/06/11 Re: 4.4.0 Release Manager Uladzislau Blok
• 2026/06/11 Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
• 2026/06/11 Re: [DISCUSS] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
• 2026/06/11 [jira] [Created] (KAFKA-20686) DLQ integ tests Sushant Mahajan (Jira)
• 2026/06/11 [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Gabriella Fu via dev
• 2026/06/11 [jira] [Created] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash Eswarar Siva (Jira)
• 2026/06/11 Re: [DISCUSS] KIP-1332: Dynamic memory allocation for the Kafka producer Jun Rao via dev
• 2026/06/11 Re: [DISCUSS] KIP-1305: Per-Record Context Processing for Kafka Consumers Aditya Kousik
• 2026/06/11 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/11 Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Luke Chen
• 2026/06/10 RE: Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams Zhao, Guang via dev
• 2026/06/10 Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups Chia-Ping Tsai
• 2026/06/10 [jira] [Resolved] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback Matthias J. Sax (Jira)
• 2026/06/10 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/10 Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Alieh Saeedi via dev
• 2026/06/10 [jira] [Resolved] (KAFKA-20652) Improve/Fix java docs Jess Jin (Jira)
• 2026/06/10 [jira] [Resolved] (KAFKA-18862) Review testHeartbeatResponseOnErrorHandling duplicate logic in ShareHeartbeatRequestManagerTest Lianet Magrans (Jira)
• 2026/06/10 [jira] [Created] (KAFKA-20684) Add Deprecated anno for ConsumerRebalanceListener class/methods Aditya Kousik (Jira)
• 2026/06/10 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/10 [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
• 2026/06/10 [jira] [Resolved] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench Lucy Liu (Jira)
• 2026/06/10 Re: [DISCUSS] KIP-1350: Expose Streams Group Heartbeat Statuses as Kafka Streams Metrics Alieh Saeedi via dev
• 2026/06/10 Re: 4.4.0 Release Manager Matthias J. Sax
• 2026/06/10 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub
• 2026/06/10 [jira] [Resolved] (KAFKA-20444) Align TxnOffsetCommit API with OffsetCommit API (KIP-1319) David Jacot (Jira)
• 2026/06/10 [jira] [Resolved] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics David Jacot (Jira)
• 2026/06/10 [jira] [Resolved] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer Lianet Magrans (Jira)
• 2026/06/10 Re: 4.4.0 Release Manager Chia-Ping Tsai
• 2026/06/10 Re: 4.4.0 Release Manager Omnia Ibrahim
• 2026/06/09 [jira] [Created] (KAFKA-20683) Add broker side custom assignors for "streams" groups Matthias J. Sax (Jira)
• 2026/06/09 Re: [DISCUSS] KIP-1350: Expose Streams Group Heartbeat Statuses as Kafka Streams Metrics Sanghyeok An
• 2026/06/09 Re: [DISCUSS] KIP-1321: Headers aware StreamPartitioner Alieh Saeedi via dev
• 2026/06/09 Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
• 2026/06/09 [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
• 2026/06/09 Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
• 2026/06/09 Re: [DISCUSS] KIP-1279: Cluster Mirroring Andrew Schofield
• 2026/06/09 Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Andrew Schofield
• 2026/06/09 [jira] [Created] (KAFKA-20682) Implement IQv2 for headers-aware state stores Alieh Saeedi (Jira)
• 2026/06/09 [jira] [Created] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer Lianet Magrans (Jira)
• 2026/06/09 Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Bill Bejeck
• 2026/06/09 Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
• 2026/06/09 [jira] [Resolved] (KAFKA-20672) Handle ARCHIVING records in share partition initialize Apoorv Mittal (Jira)
• 2026/06/09 [jira] [Created] (KAFKA-20680) Prevent stale revocation state when Streams static member temporarily leaves sanghyeok An (Jira)
• 2026/06/09 [jira] [Resolved] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart Bill Bejeck (Jira)
• 2026/06/09 Re: [ANNOUNCE] Apache Kafka 4.2.1 Andrew Schofield
• 2026/06/09 [jira] [Created] (KAFKA-20679) Remove deprecated Yammer-based group coordinator metrics Nick Guo (Jira)
• 2026/06/09 Re: [DISCUSS] KIP-1313: Client instance ID in all request headers Andrew Schofield
• 2026/06/09 [jira] [Created] (KAFKA-20678) Analyze and impl fetch from remote storage for DLQ Sushant Mahajan (Jira)
• 2026/06/08 [jira] [Created] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic Chia-Ping Tsai (Jira)
• 2026/06/08 [jira] [Resolved] (KAFKA-14276) Clarify java doc for ProcessorAPI init method and stateStore.approximateNumEntries() Matthias J. Sax (Jira)
• 2026/06/08 [jira] [Created] (KAFKA-20676) Broker fails to start when ssl.cipher.suites contains ciphers unavailable in the JSSE provider Jira
• 2026/06/08 Re: [PR] KAFKA-20541 : Move 42/generated from static/ to content/ [kafka-site] via GitHub

• Earlier messages