Re: [VOTE] KIP-1118: Add Deadlock Protection on Producer Network Thread

Hello everyone, Happy New Year 😊 I'm writing to inform you that the vote is now closed. The KIP-1118 has been accepted with 3 binding +1s from Chia-Ping, Andrew, and Kamal, as well as 3 non-binding +1s from Kirk, TaiJu, and 郭骏旺. Thank you all for your participation! Sincerely, TengYao Kamal Cha

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #167

See

[DISCUSS] KIP-1095: Kafka Canary Isolation

Hi Everyone, Started a thread to discuss KIP-1095: Kafka Canary Isolation (link ) Canary isolation aims to improve Kafka service quality by reducing blast radius of bad Kafka deployment to a small portion of tr

[jira] [Created] (KAFKA-18395) Initialize KafkaRaftMetrics without QuorumState to prevent circularity

Kevin Wu created KAFKA-18395: Summary: Initialize KafkaRaftMetrics without QuorumState to prevent circularity Key: KAFKA-18395 URL: https://issues.apache.org/jira/browse/KAFKA-18395 Project: Kafka

[jira] [Created] (KAFKA-18397) Fix the scenario where acknowledgement callback is being called on null acknowledgements

Chirag Wadhwa created KAFKA-18397: - Summary: Fix the scenario where acknowledgement callback is being called on null acknowledgements Key: KAFKA-18397 URL: https://issues.apache.org/jira/browse/KAFKA-18397

[jira] [Resolved] (KAFKA-18273) Implement kafka-share-groups.sh --describe --verbose

[ https://issues.apache.org/jira/browse/KAFKA-18273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18273. -- Resolution: Fixed > Implement kafka-share-groups.sh --describe --verbose > ---

[jira] [Resolved] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4273. Fix Version/s: 2.1.0 Resolution: Fixed > Streams DSL - Add TTL / retention period su

[jira] [Resolved] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4212. Fix Version/s: 2.1.0 Resolution: Fixed > Add a key-value store that is a TTL persist

[VOTE] KIP-1107: Adding topic-level acks and compressions for producers

Hello everyone, Happy New Year! There is no response about KIP-1107 for a long time so I would like to vote. Discussion thread: https://lists.apache.org/thread/v1sm6c59j5wppg1w6t17bvkgqlt3orp7 KIP-1107 https://cwiki.apache.org/confluence/display/KAFKA/KIP-1107%3A++Adding+topic-level+acks+and+com

Re: [VOTE] KIP-1107: Adding topic-level acks and compressions for producers

hi TaiJuWu I propose that we engage in further discussions before initiating the voting process. This KIP involves substantial changes to the producer, and it's essential to ensure we have thoroughly considered all perspectives. Best, Chia-Ping On 2025/01/03 03:03:03 TaiJu Wu wrote: > Hello ev

Re: [VOTE] KIP-1107: Adding topic-level acks and compressions for producers

Hi Chia-Ping Thanks for your reply. I will bump discussion thread and discuss it again. Best, TaiJuWu Chia-Ping Tsai 於 2025年1月3日 週五 上午11:33寫道： > hi TaiJuWu > > I propose that we engage in further discussions before initiating the > voting process. This KIP involves substantial changes to the p

Re: [DISCUSS]KIP-1107: Adding record-level acks for producers

Hello folk, This thread is pending for a long time, I want to bump this thread and get more feedback. Any questions are welcome. Best, TaiJuWu TaiJu Wu 於 2024年11月23日 週六 下午9:15寫道： > Hi Chia-Ping, > > Sorry for late reply and thanks for your feedback to make this KIP more > valuable. > After ini

[jira] [Created] (KAFKA-18396) Migrate log4j1 configuration to log4j2 in KafkaDockerWrapperTest

TengYao Chi created KAFKA-18396: --- Summary: Migrate log4j1 configuration to log4j2 in KafkaDockerWrapperTest Key: KAFKA-18396 URL: https://issues.apache.org/jira/browse/KAFKA-18396 Project: Kafka

[jira] [Created] (KAFKA-18390) Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder

Chia-Ping Tsai created KAFKA-18390: -- Summary: Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder Key: KAFKA-18390 URL: https://issues.apache.org/jira/browse/KAFKA-18390 Project

[jira] [Created] (KAFKA-18391) Skip running "Flaky Test Report" job on forks

Vadym Zhytkevych created KAFKA-18391: Summary: Skip running "Flaky Test Report" job on forks Key: KAFKA-18391 URL: https://issues.apache.org/jira/browse/KAFKA-18391 Project: Kafka Issue T

Re: [DISCUSS] KIP-1114 Introducing Chunk in Partition

Hey De Gao, thanks for the KIP! As you’re probably aware, a Partition is a logical construct in Kafka. A broker hosts a partition which is composed of physical log segments. Only the active segment is being written to and the others are immutable. The concept of a Chunk sounds quite similar to our

Re: [DISCUSS] KIP-1114 Introducing Chunk in Partition

Hi Deo, Thanks for the KIP! "However the limit of messages in a single partition replica is very big. This could lead to very big partitions (~TBs). Moving those partitions are very time consuming and have a big impact on system performance." One way to do faster rebalance is to have a latest-of

[jira] [Created] (KAFKA-18392) Require client-generated member IDs for ShareGroupHeartbeat

Andrew Schofield created KAFKA-18392: Summary: Require client-generated member IDs for ShareGroupHeartbeat Key: KAFKA-18392 URL: https://issues.apache.org/jira/browse/KAFKA-18392 Project: Kafka

Re: [VOTE] KIP-1118: Add Deadlock Protection on Producer Network Thread

+1 (binding). Thanks for the KIP! On Mon, Dec 23, 2024, 08:28 TengYao Chi wrote: > Hi everyone, > > As the vote has been pending for a week, I would like to bump it manually. > Thank you for your attention. > > Sincerely, > TengYao > > Andrew Schofield 於 2024年12月16日 週一 > 下午10:25寫道： > > > +1 (bi

[jira] [Created] (KAFKA-18393) Remove code deprecated to implement KIP-1043

Andrew Schofield created KAFKA-18393: Summary: Remove code deprecated to implement KIP-1043 Key: KAFKA-18393 URL: https://issues.apache.org/jira/browse/KAFKA-18393 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-15920) Flaky test - PlaintextConsumerTest.testCoordinatorFailover

[ https://issues.apache.org/jira/browse/KAFKA-15920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-15920. -- Resolution: Fixed > Flaky test - PlaintextConsumerTest.testCoordinatorFailover > -

[jira] [Resolved] (KAFKA-18036) TransactionsWithTieredStoreTest testReadCommittedConsumerShouldNotSeeUndecidedData is flaky

[ https://issues.apache.org/jira/browse/KAFKA-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-18036. -- Resolution: Fixed > TransactionsWithTieredStoreTest > testReadCommittedConsumerShouldNotSeeUn

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi PoAn, thanks for looking into the KIP! PY1: You are right, zkBroker was added following KIP-848 during development, and is indeed not required anymore. We don't want to allow these RPCs on the controller, so we have to remove `zkBroker`, not replace it with `controller`. I updated the KIP, I s

[jira] [Created] (KAFKA-18394) Formalize durable and in-memory election state changes

Alyssa Huang created KAFKA-18394: Summary: Formalize durable and in-memory election state changes Key: KAFKA-18394 URL: https://issues.apache.org/jira/browse/KAFKA-18394 Project: Kafka Issue