Re: [DISCUSS] KIP-1073 Return inactive observer nodes in DescribeQuorum response

2024-09-12 Thread Gantigmaa Selenge
Thank you Jose. > I think that we should always output the RACK column even if all of the nodes do not contain rack information. This would make it easier for Kafka operators that develop scripts which use and parse CLI outputs. What do you think? That makes sense to me, so I updated the KIP and

[jira] [Created] (KAFKA-17533) Threads get blocked on Kafka Streams RocksDBStore.get() API

2024-09-12 Thread Rafal (Jira)
Rafal created KAFKA-17533: - Summary: Threads get blocked on Kafka Streams RocksDBStore.get() API Key: KAFKA-17533 URL: https://issues.apache.org/jira/browse/KAFKA-17533 Project: Kafka Issue Type: Bu

Re: [DISCUSS] KIP-1050: Consistent error handling for Transactions

2024-09-12 Thread Kaushik Raina
Thanks for review Matthias 100/101 - Updated in KIP 104 - Added explicitly `For Producer-Retriable errors, the producer handles retries internally, keeping the failure details hidden from the application. Conversely, other types of exceptions will be surfaced to the application code for handling.

[jira] [Resolved] (KAFKA-17410) Flaky test testPollThrowsInterruptExceptionIfInterrupted for new consumer

2024-09-12 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-17410. Reviewer: Lianet Magrans Resolution: Fixed > Flaky test testPollThrowsInterruptExcep

[jira] [Created] (KAFKA-17534) Allow disabling hearbeats topic replication in MirrorSourceConnector

2024-09-12 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-17534: Summary: Allow disabling hearbeats topic replication in MirrorSourceConnector Key: KAFKA-17534 URL: https://issues.apache.org/jira/browse/KAFKA-17534 Project: Kafka

[DISCUSS] KIP-1089: Allow disabling heartbeats replication in MirrorSourceConnector

2024-09-12 Thread Dániel Urbán
Hi everyone, I'd like to kick off the discussion of a small improvement in the MirrorSourceConnector: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1089%3A+Allow+disabling+heartbeats+replication+in+MirrorSourceConnector The change would be fairly simple, and enables some more advanced use-c

Re: [DISCUSS] Mirroring the Repartition Topic: MirrorMaker2 and Streams interaction

2024-09-12 Thread Greg Harris
Hey everyone, Bumping this topic to see if anyone has experience migrating Streams jobs between clusters with Mirror Maker, and how you handled repartition topics. Thanks! Greg On Mon, Aug 12, 2024 at 8:55 AM Greg Harris wrote: > Hi all, > > We were recently working to set up a MirrorMaker2 fl

[jira] [Created] (KAFKA-17535) Flaky testCloseNoWait in KafkaConsumerTest for Classic Consumer

2024-09-12 Thread Lianet Magrans (Jira)
Lianet Magrans created KAFKA-17535: -- Summary: Flaky testCloseNoWait in KafkaConsumerTest for Classic Consumer Key: KAFKA-17535 URL: https://issues.apache.org/jira/browse/KAFKA-17535 Project: Kafka

[jira] [Created] (KAFKA-17536) Ensure clear error message when "new" consumer used with incompatible cluster

2024-09-12 Thread Kirk True (Jira)
Kirk True created KAFKA-17536: - Summary: Ensure clear error message when "new" consumer used with incompatible cluster Key: KAFKA-17536 URL: https://issues.apache.org/jira/browse/KAFKA-17536 Project: Kafk

[VOTE] KIP-1086: Add ability to specify a custom produce request parser.

2024-09-12 Thread Maxim Fortun
Hello everyone, I would like to call for a vote on KIP-1086: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=318606528 Discussion: https://lists.apache.org/thread/wtgt9jql43qmfsmvqcz0y1phc2n08440 Thank you, Max

[jira] [Resolved] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17253. - Fix Version/s: 4.0.0 Resolution: Fixed > Remove leaking getter methods in Joined

[jira] [Created] (KAFKA-17537) Remove deprecates methods from Joined class

2024-09-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17537: --- Summary: Remove deprecates methods from Joined class Key: KAFKA-17537 URL: https://issues.apache.org/jira/browse/KAFKA-17537 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-17538) Make deprecated *_DOC variable private/package-privste

2024-09-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17538: --- Summary: Make deprecated *_DOC variable private/package-privste Key: KAFKA-17538 URL: https://issues.apache.org/jira/browse/KAFKA-17538 Project: Kafka

[jira] [Resolved] (KAFKA-17427) Fix leaking *_DOC variables in StreamsConfig

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17427. - Fix Version/s: 4.0.0 Resolution: Fixed > Fix leaking *_DOC variables in StreamsCo

Build Updates for week of Sep 9, 2024

2024-09-12 Thread David Arthur
A lot has been happening with the GitHub Actions build in the past few weeks. I thought I would share some updates. *Build Statistics* Now that we have all PRs builds running the test suite (see note below), we can do a better comparison between GH and Jenkins Github Actions Successful trunk buil

[jira] [Created] (KAFKA-17539) Implement registerMetricsForSubscription

2024-09-12 Thread Andrew Schofield (Jira)
Andrew Schofield created KAFKA-17539: Summary: Implement registerMetricsForSubscription Key: KAFKA-17539 URL: https://issues.apache.org/jira/browse/KAFKA-17539 Project: Kafka Issue Type:

Re: Build Updates for week of Sep 9, 2024

2024-09-12 Thread Josep Prat
Thanks for the great summary David! GH CI looks indeed really good. Best, -- Josep Prat Open Source Engineering Director, Aiven josep.p...@aiven.io | +491715557497 | aiven.io Aiven Deutschland GmbH Alexanderufer 3-7, 10117 Berlin Geschäftsführer: Oskari Saarenmaa, Hannu Valtone

[jira] [Created] (KAFKA-17540) Create floating tag on trunk for CI

2024-09-12 Thread David Arthur (Jira)
David Arthur created KAFKA-17540: Summary: Create floating tag on trunk for CI Key: KAFKA-17540 URL: https://issues.apache.org/jira/browse/KAFKA-17540 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-17541) Improve handling of delivery count

2024-09-12 Thread Andrew Schofield (Jira)
Andrew Schofield created KAFKA-17541: Summary: Improve handling of delivery count Key: KAFKA-17541 URL: https://issues.apache.org/jira/browse/KAFKA-17541 Project: Kafka Issue Type: Sub-ta

[jira] [Created] (KAFKA-17542) Use actions/labeler for automatic PR labeling

2024-09-12 Thread David Arthur (Jira)
David Arthur created KAFKA-17542: Summary: Use actions/labeler for automatic PR labeling Key: KAFKA-17542 URL: https://issues.apache.org/jira/browse/KAFKA-17542 Project: Kafka Issue Type: Tas

[jira] [Created] (KAFKA-17543) Enforce that broker.id.generation.enable is disabled when migrating to KRaft

2024-09-12 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-17543: Summary: Enforce that broker.id.generation.enable is disabled when migrating to KRaft Key: KAFKA-17543 URL: https://issues.apache.org/jira/browse/KAFKA-17543 Project:

Re: Build Updates for week of Sep 9, 2024

2024-09-12 Thread Chia-Ping Tsai
Thanks for David to bring this great improvement to Kafka CI!!! Best regards, Chia-Ping Josep Prat 於 2024年9月13日 週五 上午2:29寫道: > Thanks for the great summary David! > GH CI looks indeed really good. > > Best, > -- > Josep Prat > Open Source Engineering Director, Aiven > josep.p...

[jira] [Created] (KAFKA-17544) Add a log message for KafkaShareConsumer early access

2024-09-12 Thread Andrew Schofield (Jira)
Andrew Schofield created KAFKA-17544: Summary: Add a log message for KafkaShareConsumer early access Key: KAFKA-17544 URL: https://issues.apache.org/jira/browse/KAFKA-17544 Project: Kafka