dev  

Messages by Thread

• • Re: [DISCUSS] KIP-1306: RebalanceHandler: Consumer-Aware Rebalance Callback Aditya Kousik
  • Re: [DISCUSS] KIP-1306: RebalanceHandler: Consumer-Aware Rebalance Callback Matthias J. Sax
  • Re: [DISCUSS] KIP-1306: RebalanceHandler: Consumer-Aware Rebalance Callback Aditya Kousik
  • Re: [DISCUSS] KIP-1306: RebalanceHandler: Consumer-Aware Rebalance Callback Matthias J. Sax
• [jira] [Resolved] (KAFKA-20638) Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20643) Share common implementation for downstream offset translation boundary in MirrorMaker offset syncs Jheng-Sing Chen (Jira)
• [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20642) Support character ranges in Kafka shell globs Jheng-Sing Chen (Jira)
• [DISCUSS] Apache Kafka 4.3.1 release Bill Bejeck
• Re: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share Groups Shekhar Prasad Rajak via dev
  • Re: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share Groups Shekhar Prasad Rajak via dev
  • Re: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share Groups Andrew Schofield
  • Re: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share Groups Andrew Schofield
  • Re: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share Groups Shekhar Prasad Rajak via dev
• Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1320: Deprecate org.apache.kafka.common.utils.Utils and introduce an internal replacement Eric Chang
• [jira] [Created] (KAFKA-20641) ConsumerGroup should clean up the state when a static member temporarily leaves sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled David Jacot (Jira)
• [jira] [Created] (KAFKA-20639) Move EnvelopeUtils to server module majialong (Jira)
• [jira] [Created] (KAFKA-20638) se Locale.ROOT in ConsumerGroupCommand.toLowerCase() Basivi Vanga (Jira)
• [PR] MINOR: Add note for 4.3 memory regression [kafka-site] via GitHub
  • Re: [PR] MINOR: Add note for 4.3 memory regression [kafka-site] via GitHub
• Re: [PR] docs: update 'Testing a Streams Application' example code [kafka-site] via GitHub
  • Re: [PR] docs: update 'Testing a Streams Application' example code [kafka-site] via GitHub
  • Re: [PR] docs: update 'Testing a Streams Application' example code [kafka-site] via GitHub
  • Re: [PR] docs: update 'Testing a Streams Application' example code [kafka-site] via GitHub
• Re: [PR] MINOR: KAFKA-20100: Fix broken links in Developer Guide [kafka-site] via GitHub
  • Re: [PR] MINOR: KAFKA-20100: Fix broken links in Developer Guide [kafka-site] via GitHub
• [VOTE]: KIP-1306 Extend ConsumerRebalanceListener with Consumer-aware methods Aditya Kousik
  • Re: [VOTE]: KIP-1306 Extend ConsumerRebalanceListener with Consumer-aware methods Chia-Ping Tsai
  • Re: [VOTE]: KIP-1306 Extend ConsumerRebalanceListener with Consumer-aware methods Andrew Schofield
  • Re: [VOTE]: KIP-1306 Extend ConsumerRebalanceListener with Consumer-aware methods Omnia Ibrahim
  • Re: [VOTE]: KIP-1306 Extend ConsumerRebalanceListener with Consumer-aware methods Aditya Kousik
• [jira] [Created] (KAFKA-20637) Move ForwardingManager to server module Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-10884) Limit the size of Fetch and FetchSnapshot response based on broker configuration Jira
• [jira] [Created] (KAFKA-20636) Use StreamsTopicFixture for the existing test cases in GroupMetadataManagerTest sanghyeok An (Jira)
• [RESULTS] [VOTE] Release Kafka version 4.2.1 PoAn Yang
• [jira] [Created] (KAFKA-20635) Spurious "Writing records..." failed errors in the group coordinator after partition leadership change David Jacot (Jira)
• [jira] [Created] (KAFKA-20634) Spurious HighWatermarkUpdate failed errors in the group coordinator after partition leadership change David Jacot (Jira)
• [jira] [Resolved] (KAFKA-18138) The controller must add all extant brokers to BrokerHeartbeatTracker when activating Kamal Chandraprakash (Jira)
• [jira] [Created] (KAFKA-20633) Update the default value of remote copy lag bytes Kamal Chandraprakash (Jira)
• [VOTE] KIP-1320: Deprecate Utils, ByteBufferInputStream, and ByteBufferOutputStream and introduce internal replacements Eric Chang
  • Re: [VOTE] KIP-1320: Deprecate Utils, ByteBufferInputStream, and ByteBufferOutputStream and introduce internal replacements Chia-Ping Tsai
• Re: [DISCUSS] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` David Jacot via dev
  • Re: [DISCUSS] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` Nick Guo
• [jira] [Resolved] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams Lucas Brutschy (Jira)
• [DISCUSS] KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL Hannes Buseyne
  • Re: [DISCUSS] KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL Alieh Saeedi via dev
  • Re: [DISCUSS] KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL Hannes Buseyne
  • Re: [DISCUSS] KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL Hannes Buseyne
• [jira] [Created] (KAFKA-20632) Code preparation and refactoring Nikita Shupletsov (Jira)
• [jira] [Created] (KAFKA-20631) Add "logical clients" concept Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19648) KIP-1170: Unify cluster metadata bootstrapping Jira
• [jira] [Created] (KAFKA-20630) Add documentation for topology description plugin feature Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20629) Add ducktape system tests for topology description plugin Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries Hector Geraldino (Jira)
• [jira] [Created] (KAFKA-20627) Add broker integration tests for topology description plugin Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20622) Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20621) Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20620) Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-17871) Source task source offset reads can block herder task cancellation Viktor Somogyi-Vass (Jira)
• [jira] [Created] (KAFKA-20619) ClusterTests may report Thread leak detected: Cleaner-0, Cleaner-1 Edoardo Comar (Jira)
• [jira] [Created] (KAFKA-20618) Streams Group Topology Description Plugin Alieh Saeedi (Jira)
• [PR] MINOR: Remove outdated note for streams group protocol in 4.2 docs [kafka-site] via GitHub
  • Re: [PR] MINOR: Remove outdated note for streams group protocol in 4.2 docs [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids Gaurav Narula (Jira)
• [VOTE] KIP-1331: Streams Group Topology Description Plugin Lucas Brutschy via dev
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Andrew Schofield
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Frank Chi via dev
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Bill Bejeck
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Sanghyeok An
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin David Jacot via dev
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Matthias J. Sax
  • Re: [VOTE] KIP-1331: Streams Group Topology Description Plugin Lucas Brutschy via dev
• [DISCUSS] Tightening time-based releases Matthias J. Sax
  • Re: [DISCUSS] Tightening time-based releases Andrew Schofield
  • Re: [DISCUSS] Tightening time-based releases Bill Bejeck
  • Re: [DISCUSS] Tightening time-based releases Ismael Juma
  • Re: [DISCUSS] Tightening time-based releases Christo Lolov
  • Re: [DISCUSS] Tightening time-based releases Matthias J. Sax
  • Re: [DISCUSS] Tightening time-based releases Chia-Ping Tsai
  • Re: [DISCUSS] Tightening time-based releases Christo Lolov
  • Re: [DISCUSS] Tightening time-based releases David Jacot
  • Re: [DISCUSS] Tightening time-based releases Matthias J. Sax
  • Re: [DISCUSS] Tightening time-based releases Chia-Ping Tsai
  • Re: [DISCUSS] Tightening time-based releases Andrew Schofield
  • Re: [DISCUSS] Tightening time-based releases Chia-Ping Tsai
  • Re: [DISCUSS] Tightening time-based releases Dejan Stojadinović
  • Re: [DISCUSS] Tightening time-based releases Matthias J. Sax
  • Re: [DISCUSS] Tightening time-based releases Muralidhar Basani via dev
  • Re: [DISCUSS] Tightening time-based releases Andrew Schofield
  • Re: [DISCUSS] Tightening time-based releases Matthias J. Sax
  • Re: [DISCUSS] Tightening time-based releases Andrew Schofield via dev
  • Re: [DISCUSS] Tightening time-based releases Chia-Ping Tsai via dev
  • Re: [DISCUSS] Tightening time-based releases Chia-Ping Tsai
• [VOTE] KIP-1307: SerDe and Interceptor metrics Aditya Kousik
  • Re: [VOTE] KIP-1307: SerDe and Interceptor metrics Aditya Kousik
  • Re: [VOTE] KIP-1307: SerDe and Interceptor metrics Aditya Kousik
  • Re: [VOTE] KIP-1307: SerDe and Interceptor metrics Aditya Kousik
  • Re: [VOTE] KIP-1307: SerDe and Interceptor metrics Aditya Kousik
• [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Mickael Maison
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Andrew Schofield
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Mickael Maison
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik via dev
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Andrew Schofield
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik via dev
  • Re: [VOTE] KIP-1308: Extend Header API for Common Value Types Aditya Kousik via dev
• [PR] KAFKA-20335: Sync 4.3 KIP-1271 Streams docs from apache/kafka [kafka-site] via GitHub
  • Re: [PR] KAFKA-20335: Sync 4.3 KIP-1271 Streams docs from apache/kafka [kafka-site] via GitHub
  • Re: [PR] KAFKA-20335: Sync 4.3 KIP-1271 Streams docs from apache/kafka [kafka-site] via GitHub
  • Re: [PR] KAFKA-20335: Sync 4.3 KIP-1271 Streams docs from apache/kafka [kafka-site] via GitHub
• [PR] Bump hugo-extended from 0.161.1 to 0.162.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.0 [kafka-site] via GitHub
• [DISCUSS] Kafka 4.3.1 bug-fix release Bill Bejeck
  • Re: [DISCUSS] Kafka 4.3.1 bug-fix release Andrew Schofield
• [jira] [Resolved] (KAFKA-16876) TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit Ziyun Fu (Jira)
• [jira] [Created] (KAFKA-20616) Close-path leaks in RocksDBStore cause native memory growth that eventually leads to OOM Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20615) Benchmark restore-path pause-resume toggle frequency to evaluate a lower resume threshold Muralidhar Basani (Jira)
• [VOTE] KIP-1289: Support Transactional Acknowledgments for Share Groups Shekhar Prasad Rajak via dev
  • Re: [VOTE] KIP-1289: Support Transactional Acknowledgments for Share Groups Andrew Schofield
• [PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka-site] via GitHub
  • Re: [PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka-site] via GitHub
  • Re: [PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka-site] via GitHub
• [PR] MINOR: Add documentation for the num-keys metric introduced by KIP-1250 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add documentation for the num-keys metric introduced by KIP-1250 [kafka-site] via GitHub
• Re: [DISCUSS] KIP-1331: Streams Group Topology Description Plugin Lucas Brutschy via dev
  • Re: [DISCUSS] KIP-1331: Streams Group Topology Description Plugin Matthias J. Sax
  • Re: [DISCUSS] KIP-1331: Streams Group Topology Description Plugin Lucas Brutschy via dev
• Re: [VOTE] KIP-1276 CIDR-based Host Patterns for ACLs Mickael Maison
  • Re: [VOTE] KIP-1276 CIDR-based Host Patterns for ACLs Maroš Orsák
  • Re: [VOTE] KIP-1276 CIDR-based Host Patterns for ACLs Andrew Schofield
  • Re: [VOTE] KIP-1276 CIDR-based Host Patterns for ACLs Christo Lolov
  • Re: [VOTE] KIP-1276 CIDR-based Host Patterns for ACLs Maroš Orsák
• [PR] Remove outdated note streams group protocol [kafka-site] via GitHub
  • Re: [PR] MINOR: Remove outdated note for streams group protocol [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20614) KIP-1351: Add --cancel-all to kafka-reassign-partitions Manan Gupta (Jira)
• [DISCUSS] KIP-1351: Add --cancel-all to kafka-reassign-partitions Manan Gupta
  • Re: [DISCUSS] KIP-1351: Add --cancel-all to kafka-reassign-partitions Manan Gupta
  • Re: [DISCUSS] KIP-1351: Add --cancel-all to kafka-reassign-partitions Manan Gupta
• native docker image and SASL_PLAIN support (blocker?) Stanislav Kozlovski
  • Re: native docker image and SASL_PLAIN support (blocker?) Mickael Maison
  • Re: native docker image and SASL_PLAIN support (blocker?) Chia-Ping Tsai
• [jira] [Created] (KAFKA-20613) Copy records in DLQ records Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20612) Share group DLQ metrics Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20611) Integration of dlq manager with QFK code Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20610) Abstract ReplicaManager dependency from SharePartition Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-20609) Use the lastModifiedTime to replace furture timestamp in deleting retentions Chia-Ping Tsai (Jira)
• Re: [DISCUSS] KIP-1308: Extend RecordHeader API for Common Value Types Aditya Kousik
  • Re: [DISCUSS] KIP-1308: Extend RecordHeader API for Common Value Types Mickael Maison
  • Re: [DISCUSS] KIP-1308: Extend RecordHeader API for Common Value Types Aditya Kousik
  • Re: [DISCUSS] KIP-1308: Extend RecordHeader API for Common Value Types Andrew Schofield
  • Re: [DISCUSS] KIP-1308: Extend RecordHeader API for Common Value Types Aditya Kousik
• Re: [DISCUSS] KIP-1307: SerDe and Interceptor Metrics Aditya Kousik
  • Re: [DISCUSS] KIP-1307: SerDe and Interceptor Metrics Mickael Maison
  • Re: [DISCUSS] KIP-1307: SerDe and Interceptor Metrics Aditya Kousik
• RE: Re: [DISCUSS] KIP-1201: Add disk threshold strategy to prevent disk full failure Amin Borjian
  • RE: [DISCUSS] KIP-1201: Add disk threshold strategy to prevent disk full failure Iman Sahebi
• Share groups and max.poll.records Jack Vanlightly
  • Re: Share groups and max.poll.records Andrew Schofield
• [jira] [Created] (KAFKA-20608) classic consumer static member rejoin can fail with GroupMaxSizeReachedException at max size sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20607) the version examine should include _index.md file Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20606) Using a Map<String, String> to replace Properties in the configuration propagation flow Chia-Ping Tsai (Jira)
• [VOTE] KIP-1335: Bounded concurrency for partition reassignment via kafka-reassign-partitions.sh Manan Gupta
  • Re: [VOTE] KIP-1335: Bounded concurrency for partition reassignment via kafka-reassign-partitions.sh Kamal Chandraprakash
• [jira] [Resolved] (KAFKA-20605) upgrade gradle action to enable the CI Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20605) upgrade gradle action to enable the CI Chia-Ping Tsai (Jira)
• Re: [DISCUSS] KIP-1323: Initialization of share group offsets from a specific offset or a file Lianet Magrans
  • Re: [DISCUSS] KIP-1323: Initialization of share group offsets from a specific offset or a file Andrew Schofield
  • Re: [DISCUSS] KIP-1323: Initialization of share group offsets from a specific offset or a file Lianet Magrans
• [jira] [Created] (KAFKA-20604) KIP-1348: Complete Built-in Exception Handler Symmetry with LogAndContinueProductionExceptionHandler Ankur Sinha (Jira)
• Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Muralidhar Basani via dev
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Matthias J. Sax
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Muralidhar Basani via dev
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Eric Chang
  • Re: [DISCUSS] KIP-1325: Add restore.buffered.records.per.partition new streams config - restore path Chia-Ping Tsai
• Re: [DISCUSS] KIP-1304 Add consumer metric about paused partitions Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1304 Add consumer metric about paused partitions PoAn Yang
  • Re: [DISCUSS] KIP-1304 Add consumer metric about paused partitions Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1304 Add consumer metric about paused partitions PoAn Yang

• Earlier messages
• Later messages