dev
Thread
Date
Earlier messages
Messages by Date
2026/07/20
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Siddhartha Devineni
2026/07/20
Re: [jira] [Resolved] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Gabriella Fu via dev
2026/07/20
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Chia-Ping Tsai
2026/07/20
[jira] [Resolved] (KAFKA-20783) Integrate async log reader fetch in DelayedShareFetch
Apoorv Mittal (Jira)
2026/07/20
Re: [DISCUSS] KIP-1364: Expose Rebalance Cause to RebalanceConsumer and Metrics
Lianet Magrans
2026/07/20
[jira] [Resolved] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key
Lucy Liu (Jira)
2026/07/20
[jira] [Resolved] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Matthias J. Sax (Jira)
2026/07/20
[jira] [Created] (KAFKA-20816) Add CIDR support also into Authorizer.authorizeByResourceType
Maros Orsak (Jira)
2026/07/20
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Alieh Saeedi via dev
2026/07/20
Re: [DISCUSS] KIP-1359: Improve usability of resetting group offsets
Alieh Saeedi via dev
2026/07/20
Re: [DISCUSS] KIP-1364: Expose Rebalance Cause to RebalanceConsumer and Metrics
Alieh Saeedi via dev
2026/07/20
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Sean Quah via dev
2026/07/20
Re: [DISCUSS] KIP-1368: Client framework name and version
Alieh Saeedi via dev
2026/07/20
Re: [DISCUSS] Any way to delete a single record from a partition?
Sri Chaitanya
2026/07/20
[jira] [Created] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4]
Krishna Chidrawar (Jira)
2026/07/20
[jira] [Resolved] (KAFKA-20772) DLQ System tests
Sanskar Jhajharia (Jira)
2026/07/20
Re: [DISCUSS] KIP-1367: Reserve apiKey values for private use
Chia-Ping Tsai
2026/07/20
Re: [DISCUSS] Any way to delete a single record from a partition?
Andrew Schofield
2026/07/20
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Chia-Ping Tsai
2026/07/19
Re: [DISCUSS] KIP-1311: Make Time/Timer public API
Chia-Ping Tsai
2026/07/19
[jira] [Resolved] (KAFKA-20814) Make Time utils class part of the public API
Chia-Ping Tsai (Jira)
2026/07/19
[jira] [Created] (KAFKA-20814) Make Time utils class part of the public API
Chia-Ping Tsai (Jira)
2026/07/19
[jira] [Created] (KAFKA-20813) docker_build_test.py doesn't like podman
Chia-Ping Tsai (Jira)
2026/07/19
[jira] [Created] (KAFKA-20812) refactor KRaftClusterTest
Chia-Ping Tsai (Jira)
2026/07/19
[jira] [Resolved] (KAFKA-18448) Support SSL protocol with java.security.auth.login.config
Chia-Ping Tsai (Jira)
2026/07/19
[jira] [Resolved] (KAFKA-16680) Make ClusterTestExtensions support SASL
Chia-Ping Tsai (Jira)
2026/07/18
Re: [DISCUSS] KIP-1265: Public API needs to be explicitly declared
Chia-Ping Tsai
2026/07/18
[jira] [Created] (KAFKA-20811) Add connector plugin version configuration and validation tests
majialong (Jira)
2026/07/18
Re: [DISCUSS] KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect
pritam kumar
2026/07/18
Re: [DISCUSS] KIP-1367: Reserve apiKey values for private use
Gaurav Narula
2026/07/17
Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #217
Apache Jenkins Server
2026/07/17
Re: [DISCUSS] KIP-1362: Add a rollback-compatible storage format option for KRaft migration
Gergely Harmadás
2026/07/17
Re: [DISCUSS] KIP-1367: Reserve apiKey values for private use
Matthias J. Sax
2026/07/17
[jira] [Resolved] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException
Matthias J. Sax (Jira)
2026/07/17
[DISCUSS] KIP-1368: Client framework name and version
Andrew Schofield
2026/07/17
[jira] [Created] (KAFKA-20810) Client framework name and version
Andrew Schofield (Jira)
2026/07/17
[jira] [Created] (KAFKA-20809) Update documentation with KIP-1191 information
Andrew Schofield (Jira)
2026/07/17
[jira] [Reopened] (KAFKA-20723) Harden ShareGroupDLQStateManager
Sushant Mahajan (Jira)
2026/07/16
Re: [DISCUSS] KIP-1265: Public API needs to be explicitly declared
Ashwin via dev
2026/07/16
[jira] [Created] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException
Matthias J. Sax (Jira)
2026/07/16
[jira] [Resolved] (KAFKA-18951) Validate client code and documentation in examples/ directory
Chia-Ping Tsai (Jira)
2026/07/16
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Muralidhar Basani via dev
2026/07/16
Re: [jira] [Resolved] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Gabriella Fu via dev
2026/07/16
Re: [DISCUSS] KIP-1359: Improve usability of resetting group offsets
Andrew Schofield
2026/07/16
Re: [DISCUSS] KIP-1364: Expose Rebalance Cause to RebalanceConsumer and Metrics
Andrew Schofield
2026/07/16
[DISCUSS] KIP-1367: Reserve apiKey values for private use
Gaurav Narula
2026/07/16
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Andrew Schofield
2026/07/16
[jira] [Resolved] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyWithHeadersQuery)
Jess Jin (Jira)
2026/07/16
[jira] [Resolved] (KAFKA-19663) kafka-broker-api tool should support to get controller api version
Chia-Ping Tsai (Jira)
2026/07/16
[jira] [Resolved] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed()
TengYao Chi (Jira)
2026/07/15
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Sushant Mahajan
2026/07/15
Re: [DISCUSS] KIP-1279: Cluster Mirroring
Jun Rao via dev
2026/07/15
[jira] [Resolved] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built
Chia-Ping Tsai (Jira)
2026/07/15
[jira] [Created] (KAFKA-20807) Refactor ByteBufferOutputStream for better extensibility
Lianet Magrans (Jira)
2026/07/15
[jira] [Resolved] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore
Bill Bejeck (Jira)
2026/07/15
Re: [VOTE] KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Lucy Liu via dev
2026/07/15
Re: [DISCUSS] KIP-1355: In-rack traffic observability for clients and brokers
Viktor Somogyi-Vass via dev
2026/07/15
[jira] [Created] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed()
Apoorv Mittal (Jira)
2026/07/15
Re: [DISCUSS] KIP-1279: Cluster Mirroring
Federico Valeri
2026/07/14
[jira] [Created] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore and OffsetOutOfRange after a StreamThread failure
Bill Bejeck (Jira)
2026/07/14
[jira] [Resolved] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions
Lianet Magrans (Jira)
2026/07/14
[jira] [Created] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add
Xi Wang (Jira)
2026/07/14
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Muralidhar Basani via dev
2026/07/14
[jira] [Created] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs
Shekhar Prasad Rajak (Jira)
2026/07/14
Re: [DISCUSS] KIP-1265: Public API needs to be explicitly declared
Chia-Ping Tsai
2026/07/14
[jira] [Resolved] (KAFKA-20768) RocksDB SegmentedStore readOnly implementation
Bill Bejeck (Jira)
2026/07/14
[jira] [Resolved] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders
Bill Bejeck (Jira)
2026/07/14
[jira] [Resolved] (KAFKA-20704) Implement query type 2 (TimestampedRangeWithHeadersQuery)
Jess Jin (Jira)
2026/07/14
[jira] [Resolved] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Apoorv Mittal (Jira)
2026/07/14
[jira] [Resolved] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Lianet Magrans (Jira)
2026/07/14
[jira] [Created] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built
Eric Chang (Jira)
2026/07/13
Re: Not able to assign the jira to myself
pritam kumar
2026/07/13
Re: [DISCUSS] KIP-1164: Diskless Coordinator
vaquar khan
2026/07/13
Re: [DISCUSS] KIP-1164: Diskless Coordinator
Greg Harris via dev
2026/07/13
[jira] [Resolved] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
Bill Bejeck (Jira)
2026/07/13
Re: Not able to assign the jira to myself
Matthias J. Sax
2026/07/13
Re: [DISCUSS] KIP-1279: Cluster Mirroring
vaquar khan
2026/07/13
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Sushant Mahajan
2026/07/13
[jira] [Resolved] (KAFKA-20723) Harden ShareGroupDLQStateManager
Sushant Mahajan (Jira)
2026/07/13
[jira] [Resolved] (KAFKA-20771) Honor DLQ topic configs so as to not overwhelm it with large produce requests.
Apoorv Mittal (Jira)
2026/07/13
Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement
Chia-Ping Tsai
2026/07/13
[DISCUSS] KIP-1366: Configurable Segment Interval for Window and Session Stores
Hannes Buseyne
2026/07/13
[jira] [Created] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores
Hannes Buseyne (Jira)
2026/07/13
Re: [PR] MINOR: Fix broken relative links across documentation [kafka-site]
via GitHub
2026/07/13
Re: [PR] KAFKA-20009: Sync doc description fix from kafka trunk to active pages [kafka-site]
via GitHub
2026/07/13
Re: [PR] KAFKA-20009: Sync doc description fix from kafka trunk to active pages [kafka-site]
via GitHub
2026/07/13
[jira] [Created] (KAFKA-20800) Adjust Kafka security logging with more context
Vladimir Yatsenko (Jira)
2026/07/13
[jira] [Resolved] (KAFKA-20761) Add client logs for consumer group configs defined on the broker
Lianet Magrans (Jira)
2026/07/13
Re: [DISCUSS] KIP-1279: Cluster Mirroring
Luke Chen
2026/07/13
Re: [DISCUSS] KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL
Hannes Buseyne
2026/07/13
[jira] [Resolved] (KAFKA-20629) Add ducktape system tests for topology description plugin
TengYao Chi (Jira)
2026/07/13
[jira] [Created] (KAFKA-20799) Introduce new error for consumer/share group name collision
Luke Chen (Jira)
2026/07/12
Re: [DISCUSS] KIP-1164: Diskless Coordinator
vaquar khan
2026/07/12
Re: [VOTE] KIP-1279: Cluster Mirroring
vaquar khan
2026/07/12
Re: [DISCUSS] KIP-1279: Cluster Mirroring
vaquar khan
2026/07/12
[jira] [Created] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders
Lucy Liu (Jira)
2026/07/12
Re: [DISCUSS] KIP-1279: Cluster Mirroring
Jun Rao via dev
2026/07/11
Re: [VOTE] KIP-1321: Headers aware StreamPartitioner
Uladzislau Blok
2026/07/11
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Lijun Tong
2026/07/11
Not able to assign the jira to myself
pritam kumar
2026/07/11
[jira] [Created] (KAFKA-20797) KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect
Pritam Kumar (Jira)
2026/07/11
[DISCUSS] KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect
pritam kumar
2026/07/10
[PR] MINOR: Fix broken relative links across documentation [kafka-site]
via GitHub
2026/07/10
[PR] MINOR: Sync doc description fix from apache/kafka#22605 to 4.3.X pages [kafka-site]
via GitHub
2026/07/10
Re: [PR] MINOR: Fix duplicate titles on docs list pages [kafka-site]
via GitHub
2026/07/10
Re: [PR] MINOR: Fix duplicate titles on docs list pages [kafka-site]
via GitHub
2026/07/10
[PR] MINOR: Fix duplicate titles on docs list pages [kafka-site]
via GitHub
2026/07/10
Re: [PR] MINOR: Fix broken links on the downloads page [kafka-site]
via GitHub
2026/07/10
Re: [PR] MINOR: Fix broken links on the downloads page [kafka-site]
via GitHub
2026/07/10
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Muralidhar Basani via dev
2026/07/10
[PR] MINOR: Fix broken links on the downloads page [kafka-site]
via GitHub
2026/07/10
[jira] [Created] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore
Jess Jin (Jira)
2026/07/10
[jira] [Created] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator
Chia-Ping Tsai (Jira)
2026/07/10
[jira] [Resolved] (KAFKA-20451) Move RequestChannel Responses to server module
Chia-Ping Tsai (Jira)
2026/07/10
[jira] [Created] (KAFKA-20794) Add documentation and tests for the RPC deprecatedVersions field
Chia-Ping Tsai (Jira)
2026/07/10
[jira] [Resolved] (KAFKA-20746) NPE in MetadataCache#toCluster
Chia-Ping Tsai (Jira)
2026/07/10
Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement
Eric Chang
2026/07/10
[jira] [Resolved] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs
Mickael Maison (Jira)
2026/07/10
[jira] [Created] (KAFKA-20793) Mark share.version=2 stable
Sushant Mahajan (Jira)
2026/07/10
[jira] [Resolved] (KAFKA-20329) Test `headers` dsl.store.format further
Alieh Saeedi (Jira)
2026/07/10
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/09
[DISCUSS] Stable short URLs for KIP references
Aditya Kousik
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Lijun Tong
2026/07/09
[jira] [Created] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
2026/07/09
Re: [DISCUSS] KIP-1349 : Configurable snapshot frequency for share groups
Sushant Mahajan
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/09
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Lijun Tong
2026/07/09
[jira] [Resolved] (KAFKA-20088) CIDR-based Host Patterns for ACLs
Mickael Maison (Jira)
2026/07/09
[jira] [Resolved] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Mickael Maison (Jira)
2026/07/09
[jira] [Resolved] (KAFKA-20791) Bump log4j to 2.25.5
Mickael Maison (Jira)
2026/07/09
[jira] [Resolved] (KAFKA-20741) Add ReadOnlyRecord Interface
Jess Jin (Jira)
2026/07/09
[DISCUSS] KIP-1362: Add a rollback-compatible storage format option for KRaft migration
Anton Agestam via dev
2026/07/09
[jira] [Created] (KAFKA-20791) Bump log4j to 2.25.5
Federico Valeri (Jira)
2026/07/09
Re: Request for JIRA contributor permissions - Devansh Srivastava
Mickael Maison
2026/07/08
Request for JIRA contributor permissions - Devansh Srivastava
Devansh Srivastava
2026/07/08
Re: [DISCUSS] KIP-1163: Diskless Core
Greg Harris via dev
2026/07/08
[jira] [Resolved] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Ziyun Fu (Jira)
2026/07/08
[jira] [Created] (KAFKA-20790) Promote streams assignor API to public module
Ziyun Fu (Jira)
2026/07/08
[jira] [Created] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Ziyun Fu (Jira)
2026/07/08
[DISCUSS] KIP-1364: Expose Rebalance Cause to RebalanceConsumer and Metrics
Aditya Kousik
2026/07/08
[jira] [Created] (KAFKA-20788) Expose Rebalance Cause to RebalanceConsumer and Metrics
Aditya Kousik (Jira)
2026/07/08
[jira] [Created] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Lucy Liu (Jira)
2026/07/08
Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups
Gabriella Fu via dev
2026/07/08
Re: [VOTE] KIP-1357: Add broker side custom assignors for "streams" groups
Gabriella Fu via dev
2026/07/08
Re: [VOTE] KIP-1357: Add broker side custom assignors for "streams" groups
Matthias J. Sax
2026/07/08
Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups
Matthias J. Sax
2026/07/08
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Chia-Ping Tsai
2026/07/08
[jira] [Resolved] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce
Lianet Magrans (Jira)
2026/07/08
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Andrew Schofield
2026/07/08
[jira] [Resolved] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation
Mickael Maison (Jira)
2026/07/08
[jira] [Resolved] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
2026/07/08
[VOTE] KIP-1279: Cluster Mirroring
Federico Valeri
2026/07/07
Re: [VOTE] KIP-1357: Add broker side custom assignors for "streams" groups
David Jacot
2026/07/07
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Chia-Ping Tsai
2026/07/07
[jira] [Created] (KAFKA-20786) Build sometimes times out on streams tests
Lianet Magrans (Jira)
2026/07/07
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Jun Rao via dev
2026/07/07
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Chia-Ping Tsai
2026/07/07
[PR] Bump hugo-extended from 0.163.3 to 0.164.0 [kafka-site]
via GitHub
2026/07/07
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Chia-Ping Tsai
2026/07/07
[jira] [Created] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout
Lianet Magrans (Jira)
2026/07/07
Re: 4.4.0 Release Manager
o . g . h . ibrahim
2026/07/07
Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups
Gabriella Fu via dev
2026/07/07
[jira] [Created] (KAFKA-20784) Change certificate management
Jira
2026/07/07
[jira] [Created] (KAFKA-20783) Integrate async log reader fetch in DelayedShareFetch
Apoorv Mittal (Jira)
2026/07/07
[jira] [Created] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
2026/07/07
[VOTE] KIP-1318: Model Context Protocol (MCP) Server for Apache Kafka
vaquar khan
2026/07/07
[jira] [Created] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Lianet Magrans (Jira)
2026/07/07
[jira] [Resolved] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
2026/07/07
Re: [DISCUSS] KIP-1279: Cluster Mirroring
Federico Valeri
2026/07/07
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
黃竣陽
2026/07/07
[DISCUSS] KIP-1363: Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot
onebywang
2026/07/07
Re: [DISCUSS] KIP-1266 Bounding The Number Of RemoteLogMetadata Messages via Compacted RemoteLogMetadata Topic
Kamal Chandraprakash
2026/07/07
[jira] [Created] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Jira
2026/07/07
[DISCUSS] KIP-1363: Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot
onebywang
2026/07/06
Re: [DISCUSS] KIP-1265: Public API needs to be explicitly declared
Ashwin via dev
2026/07/06
[jira] [Created] (KAFKA-20779) followup review on the merged KIP-1265 PR [https://github.com/apache/kafka/pull/21337]
Ashwin Pankaj (Jira)
2026/07/06
Re: [DISCUSS] KIP-1315: Split Connector Listing and Expanded Views in the Connect REST API
nileshkumar3
2026/07/06
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Jun Rao via dev
2026/07/06
Re: [DISCUSS] KIP-1303: Deprioritize Tiered Storage Followers In Leader Election
Thomas Thornton via dev
2026/07/06
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Chia-Ping Tsai
2026/07/06
[jira] [Created] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce
Lianet Magrans (Jira)
2026/07/06
[jira] [Created] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
Alan Lau (Jira)
2026/07/06
Re: [DISCUSS] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy
Jun Rao via dev
2026/07/06
Re: [VOTE] KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Lucy Liu via dev
2026/07/06
Re: [DISCUSS] KIP-1315: Split Connector Listing and Expanded Views in the Connect REST API
Mickael Maison
2026/07/06
[jira] [Created] (KAFKA-20776) MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for KeyQuery and TimestampedKeyQuery
Jess Jin (Jira)
2026/07/06
[jira] [Resolved] (KAFKA-19117) Client Throttling Log messages should be of log level - WARN (Java client)
Chia-Ping Tsai (Jira)
2026/07/06
[jira] [Created] (KAFKA-20775) Handle the possible incompatibility of `Node#idString`
Chia-Ping Tsai (Jira)
2026/07/06
Re: [jira] [Created] (KAFKA-20686) DLQ integ tests
J Rivers
2026/07/06
[jira] [Resolved] (KAFKA-14228) Support for nested structures: ValueToKey
Mickael Maison (Jira)
2026/07/06
[jira] [Created] (KAFKA-20774) ScramDelta.apply() drops SCRAM users when processing REMOVE records for absent users or multiple removals in one batch
Mikhail Fomichev (Jira)
2026/07/06
[jira] [Created] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Krishna Chidrawar (Jira)
2026/07/06
[jira] [Resolved] (KAFKA-15828) Protect clients from broker hostname reuse
Andrew Schofield (Jira)
2026/07/06
[jira] [Resolved] (KAFKA-20246) Detection and handling of misrouted connections
Andrew Schofield (Jira)
2026/07/06
[jira] [Created] (KAFKA-20772) DLQ System tests
Sushant Mahajan (Jira)
2026/07/05
[jira] [Created] (KAFKA-20771) Honor DLQ topic max message bytes so as to not overwhelm it with large produce requests.
Sushant Mahajan (Jira)
2026/07/05
[jira] [Resolved] (KAFKA-20686) DLQ integ tests
Sushant Mahajan (Jira)
Earlier messages