Re: Request for pull request review

Hello Igor, Thank you for driving this, currently we have more discussion about this, the main concern is that we don't want to add an RPC which will be O(num_partitions_in_dir), please see https://issues.apache.org/jira/browse/KAFKA-9837 for

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Thank you for feedback, I've discussed this offline with some of the folks and updated the KIP. The main change is that now instead of using DefaultPartitioner and UniformStickyPartitioners as flags, in the new proposal the default partitioner is null, so if no custom partitioner is specified

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #755

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #754

See

[jira] [Resolved] (KAFKA-13717) KafkaConsumer.close throws authorization exception even when commit offsets is empty

[ https://issues.apache.org/jira/browse/KAFKA-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13717. --- Fix Version/s: 3.2.0 Assignee: Vincent Jiang Resolution: Fixed >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 2.8 #98

See Changes: -- [...truncated 467855 lines...] [2022-03-10T01:38:18.424Z] [INFO] Parameter: package, Value: myapps [2022-03-10T01:38:18.424Z] [INFO] Parameter:

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #185

See

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.1 #85

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #753

See

Re: [DISCUSS] KIP-714: Client metrics and observability

Hi Jun, On Tue, Mar 8, 2022, at 5:47 PM, Jun Rao wrote: > Hi, Magnus, Sarat and Xavier, > > Thanks for the reply. A few more comments below. > > 20. It seems that we are piggybacking the plugin on the > existing MetricsReporter. So, this seems fine. > > 21. That could work. Are we requiring

[jira] [Created] (KAFKA-13726) Fix Vulnerability CVE-2022-23181 -Upgrade org.apache.tomcat.embed_tomcat-embed-core

Chris Sabelstrom created KAFKA-13726: Summary: Fix Vulnerability CVE-2022-23181 -Upgrade org.apache.tomcat.embed_tomcat-embed-core Key: KAFKA-13726 URL: https://issues.apache.org/jira/browse/KAFKA-13726

[jira] [Created] (KAFKA-13725) KIP-768 OAuth code mixes public and internal classes in same package

Kirk True created KAFKA-13725: - Summary: KIP-768 OAuth code mixes public and internal classes in same package Key: KAFKA-13725 URL: https://issues.apache.org/jira/browse/KAFKA-13725 Project: Kafka

[jira] [Created] (KAFKA-13724) Fix Vulnerability CVE-2021-43859 - Upgrade com.thoughtworks.xstream_xstream

Chris Sabelstrom created KAFKA-13724: Summary: Fix Vulnerability CVE-2021-43859 - Upgrade com.thoughtworks.xstream_xstream Key: KAFKA-13724 URL: https://issues.apache.org/jira/browse/KAFKA-13724

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #752

See

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, Looking good! Got a few more thoughts. 1. Sorry to revisit this, but I think we may want to adopt a slightly different escape syntax style. Backslashes are great, but since they're already used by JSON, using them as an escape sequence in field notation would also lead to some pretty

[jira] [Resolved] (KAFKA-13723) max.compaction.lag.ms implemented incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-13723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13723. - Resolution: Not A Problem > max.compaction.lag.ms implemented incorrectly >

[jira] [Created] (KAFKA-13723) max.compaction.lag.ms implemented incorrectly

Jun Rao created KAFKA-13723: --- Summary: max.compaction.lag.ms implemented incorrectly Key: KAFKA-13723 URL: https://issues.apache.org/jira/browse/KAFKA-13723 Project: Kafka Issue Type: Bug

Re: [DISCUSS] Apache Kafka 3.1.1

+1. Thanks Tom! Le mer. 9 mars 2022 à 19:10, Bill Bejeck a écrit : > Thanks Tom! It's a +1 for me. > > -Bill > > On Wed, Mar 9, 2022 at 12:00 PM Ismael Juma wrote: > > > Thanks Tom. +1 > > > > Ismael > > > > > > On Wed, Mar 9, 2022 at 8:10 AM Tom Bentley wrote: > > > > > Hi, > > > > > > I'd

Re: [DISCUSS] Apache Kafka 3.1.1

Thanks Tom! It's a +1 for me. -Bill On Wed, Mar 9, 2022 at 12:00 PM Ismael Juma wrote: > Thanks Tom. +1 > > Ismael > > > On Wed, Mar 9, 2022 at 8:10 AM Tom Bentley wrote: > > > Hi, > > > > I'd like to volunteer to be the release manager for the 3.1.1 bugfix > > release. > > > > Kind regards,

[jira] [Created] (KAFKA-13722) Update internal interfaces that use ProcessorContext to use StateStoreContext instead

Guozhang Wang created KAFKA-13722: - Summary: Update internal interfaces that use ProcessorContext to use StateStoreContext instead Key: KAFKA-13722 URL: https://issues.apache.org/jira/browse/KAFKA-13722

Re: [VOTE] 3.0.1 RC0

Hi Mickael, Thanks for running the release. I did the following steps to validate the release: 1. Validated signatures and checksums 2. Built from source and ran the unit tests 3. I ran the quickstart steps for ZK and Kafka Streams 4. Spot checked the docs and Javadocs I notice the

Re: [DISCUSS] Apache Kafka 3.1.1

Thanks Tom. +1 Ismael On Wed, Mar 9, 2022 at 8:10 AM Tom Bentley wrote: > Hi, > > I'd like to volunteer to be the release manager for the 3.1.1 bugfix > release. > > Kind regards, > > Tom >

[jira] [Created] (KAFKA-13721) Left-join still emit spurious results in stream-stream joins in some cases

Nollet created KAFKA-13721: -- Summary: Left-join still emit spurious results in stream-stream joins in some cases Key: KAFKA-13721 URL: https://issues.apache.org/jira/browse/KAFKA-13721 Project: Kafka

[DISCUSS] Apache Kafka 3.1.1

Hi, I'd like to volunteer to be the release manager for the 3.1.1 bugfix release. Kind regards, Tom

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #751

See

Re: Newbie contributor

Hi Francisco, Welcome! I've added you to the contributor list. Thanks for your interest in Apache Kafka. Thanks, Mickael On Wed, Mar 9, 2022 at 4:16 PM Francisco José Becerra López wrote: > > Hi, > > Hope you are well > > May I be added to the contribution list to lend a hand on this project,

Re: [VOTE] 3.0.1 RC0

Thanks for running the release, Mickael. I performed the following validations: * Verified all checksums and signatures. * Built from source and ran unit tests. * Ran the first quickstart steps for both ZK and KRaft. * Spotchecked the Javadocs. However, the document still references 3.0.0 in all

[DISCUSS] [KIP worthy?] Anyone with large clusters facing Produce Response Time degradation as in KAFKA-10690?

Hello, This is Arun from LINE Corporation. We have a cluster with a large number of brokers (200+), node failures are bound to happen relatively often. Upon recovery of the machine, or upon reassignment of the replicas on failed node, we often have a large amount of lagging replica catch up.

Newbie contributor

Hi, Hope you are well May I be added to the contribution list to lend a hand on this project, please? Jira username: fjbecerra Regards Francisco

Request for pull request review

Can someone review this pull request please? https://github.com/apache/kafka/pull/9577 It has been open for quite some time, and it seems pinging folks directly on GitHub has not worked. Thanks, -- Igor

[jira] [Created] (KAFKA-13720) Few topic partitions remain under replicated after broker lose connectivity to zookeeper

Dhirendra Singh created KAFKA-13720: --- Summary: Few topic partitions remain under replicated after broker lose connectivity to zookeeper Key: KAFKA-13720 URL: https://issues.apache.org/jira/browse/KAFKA-13720

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #750

See

[jira] [Created] (KAFKA-13719) connector restart cause duplicate tasks

Shujie Sun created KAFKA-13719: -- Summary: connector restart cause duplicate tasks Key: KAFKA-13719 URL: https://issues.apache.org/jira/browse/KAFKA-13719 Project: Kafka Issue Type: Bug

Re: [VOTE] 3.0.1 RC0

Hi Mickael, In addition to the results others have posted I've also validated the checksums and keys, built from source and executed the unit and integration tests. Overall I'm +1 (binding). Thanks, Tom On Wed, 9 Mar 2022 at 07:55, Michal Tóth wrote: > Hello, > > executed

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #749

See