[jira] [Resolved] (KAFKA-18116) Admin LeaveGroup fails for static consumer group member

[ https://issues.apache.org/jira/browse/KAFKA-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-18116. - Resolution: Fixed Addressed by https://github.com/apache/kafka/pull/17976. > Admin LeaveGroup f

[jira] [Resolved] (KAFKA-17598) Command line validation tool for RE2J regex

[ https://issues.apache.org/jira/browse/KAFKA-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17598. - Fix Version/s: 4.0.0 Resolution: Fixed > Command line validation tool for RE2J regex > --

Re: [DISCUSS] KIP-1030: Change constraints and default values for various configurations

Hi Divij, The KIP didn't state this, but the usual practice is to have a deprecation period before we make incompatible changes. Why did we reject this option? We should mention that explicitly in the KIP. Ismael On Tue, Nov 19, 2024, 2:55 AM Divij Vaidya wrote: > KT1 - That is right. We will

[jira] [Resolved] (KAFKA-18050) Upgrade the checkstyle version to 10.20.2

[ https://issues.apache.org/jira/browse/KAFKA-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18050. Fix Version/s: 4.0.0 Resolution: Fixed > Upgrade the checkstyle version to 10.20.2

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #119

See

[jira] [Resolved] (KAFKA-18132) Remove "session.timeout.ms" from connect-distributed.properties to fix connect e2e

[ https://issues.apache.org/jira/browse/KAFKA-18132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18132. Fix Version/s: 4.0.0 Resolution: Fixed > Remove "session.timeout.ms" from connect-d

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

See

[jira] [Created] (KAFKA-18161) Revisit connect e2e

Chia-Ping Tsai created KAFKA-18161: -- Summary: Revisit connect e2e Key: KAFKA-18161 URL: https://issues.apache.org/jira/browse/KAFKA-18161 Project: Kafka Issue Type: Improvement R

[jira] [Created] (KAFKA-18160) Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped, potentially leading to corru

Chia-Ping Tsai created KAFKA-18160: -- Summary: Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped, potentially leading to corrupted added partitions

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #215

See

[jira] [Created] (KAFKA-18159) Remove onPartitionsRevoked and onPartitionsAssigned from SinkTask

Chia-Ping Tsai created KAFKA-18159: -- Summary: Remove onPartitionsRevoked and onPartitionsAssigned from SinkTask Key: KAFKA-18159 URL: https://issues.apache.org/jira/browse/KAFKA-18159 Project: Kafka

Re: [DISCUSS] New "asf-committers" branch

Thanks to a tip from an Apache Arrow committer, I found another way to check if a GH user was a committer. This solves the issue I was facing for the "triage" label workflow. For future automations, we may still consider including a list of committers in the source (whether on an orphaned branch o

Re: [VOTE] 3.7.2 RC1

Matthias, Thanks for running the release. I did the following steps: - Validated the checksums and keys - Built from source - Ran all the unit tests - Spot checked the javadocs - Spot checked the documentation - Ran the KRaft quickstart - Pulled and started the docker image

[jira] [Resolved] (KAFKA-17783) Remove sharePartition from SharePartitionManager if the partition is deleted or becomes a follower

[ https://issues.apache.org/jira/browse/KAFKA-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17783. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Remove sharePartition from Share

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

Hi TengYao, I do think there's more to explore in this area, but I'll concede that keeping the scope of this KIP small is better. The need for a KIP really boils to the fact that we're modifying the flush() contract to add another case where an exception can be thrown. From that standpoint it

Re: [DISCUSS] KIP-1111: Enforcing Explicit Naming for Kafka Streams Internal Topics

Hi All, Thanks for the KIP, Sébastien, this will be a very useful addition. I don't have any additional comments at this point, but I'd like to add a +1 for current naming of `ensure.explicit.internal.resource.naming`. I think it strikes the correct balance among all the suggestions on this threa

[jira] [Resolved] (KAFKA-17460) Remove downgrade_test.py as it is duplicate to kraft_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17460. Resolution: Fixed > Remove downgrade_test.py as it is duplicate to kraft_upgrade_test.py

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #118

See

Re: [VOTE] KIP-1034: Dead letter queue in Kafka Streams

Hi all, During the implementation of the KIP, we realized that the proposal adds some mutable fields to enums: - ProductionExceptionHandlerResponse from ProductionExceptionHandler - DeserializationHandlerResponse from DeserializationExceptionHandler - ProcessingHandlerResponse from ProcessingExc

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #214

See

[VOTE] 3.7.2 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 3.7.2. This is a bug-fix release, closing 21 Jira tickets. Release notes for the 3.7.2 release: https://dist.apache.org/repos/dist/dev/kafka/3.7.2-rc1/RELEASE_NOTES.html Please dow

Re: [DISCUSS] KIP-1111: Enforcing Explicit Naming for Kafka Streams Internal Topics

Hi, BC+1: I have updated the KIP with ensure.explicit.internal.resource.naming (default: false) as Bruno suggested. BC+2: Implementation details have been removed. Regarding the issue with "DSL/StreamsBuilder" configs, I will open a separate KIP once this one is definitively accepted or reje

[VOTE] [CANCELED] 3.7.2 RC0

Hi, I just wanted to give a status update on 3.7.2 release. While working on RC0, we found a CVE that needs to be fixed (already fixed in trunk, 3.9, and 3.8, so I just need to cherry-pick the commit). However, some artifacts for RC0 got already published while preparing the RC, thus we need

Re: [DISCUSS] New "asf-committers" branch

Thanks for the pointers, everyone. Lots of TIL :) The kafka-committers team is a "secret" team in GH, so I don't think the GH automation will be able to access it. I'll follow up with Infra to see if there's a way. That would definitely be the simplest solution. Mickael, the idea behind the orpha

[VOTE] [CANCELED] 3.7.2 RC0

Hi, I just wanted to give a status update on 3.7.2 release. While working on RC0, we found a CVE that needs to be fixed (already fixed in trunk, 3.9, and 3.8, so I just need to cherry-pick the commit). However, some artifacts for RC0 got already published while preparing the RC, thus we need

Re: [DISCUSS] New "asf-committers" branch

The committer information is also publicly available in a json format at https://whimsy.apache.org/public/public_ldap_projects.json We can choose to parse the json to extract the committers. It won't require any authentication to generate our file. -- Divij Vaidya On Wed, Dec 4, 2024 at 10:56 

[jira] [Created] (KAFKA-18158) Add subscribePattern integration tests for subsequent subscription

Lianet Magrans created KAFKA-18158: -- Summary: Add subscribePattern integration tests for subsequent subscription Key: KAFKA-18158 URL: https://issues.apache.org/jira/browse/KAFKA-18158 Project: Kafka

[jira] [Resolved] (KAFKA-18096) Allow new consumer to join group after subscribe to pattern if no matching topics

[ https://issues.apache.org/jira/browse/KAFKA-18096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-18096. Resolution: Fixed > Allow new consumer to join group after subscribe to pattern if no matc

[jira] [Resolved] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-15561. Resolution: Fixed > Client support for new SubscriptionPattern based subscription > --

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

Hi Andrew, thanks for the comments! You are right, we haven't fully caught up with the changed that were made in the final version of KIP-1043. I agree with all your points, and have made the corresponding changes in the KIP. Cheers, Lucas On Tue, Dec 3, 2024 at 6:51 PM Andrew Schofield wrote:

[jira] [Resolved] (KAFKA-18153) remove jenkins settings from settings.gradle

[ https://issues.apache.org/jira/browse/KAFKA-18153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18153. Fix Version/s: 4.0.0 Resolution: Fixed > remove jenkins settings from settings.grad

[jira] [Created] (KAFKA-18157) Consider UnsupportedVersionException child class to represent the case of unsupported fields

Lianet Magrans created KAFKA-18157: -- Summary: Consider UnsupportedVersionException child class to represent the case of unsupported fields Key: KAFKA-18157 URL: https://issues.apache.org/jira/browse/KAFKA-18157

[jira] [Created] (KAFKA-18156) VerifiableConsumer should ignore "--session-timeout" when using CONSUMER protocol

Chia-Ping Tsai created KAFKA-18156: -- Summary: VerifiableConsumer should ignore "--session-timeout" when using CONSUMER protocol Key: KAFKA-18156 URL: https://issues.apache.org/jira/browse/KAFKA-18156

[jira] [Resolved] (KAFKA-18127) Handle subscription pattern used with v0 HB broker

[ https://issues.apache.org/jira/browse/KAFKA-18127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18127. Resolution: Fixed > Handle subscription pattern used with v0 HB broker > -

[jira] [Resolved] (KAFKA-18152) add 0.11, 1.0, 1.1, and 2.0 streams dependencies to dockerfile

[ https://issues.apache.org/jira/browse/KAFKA-18152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18152. Fix Version/s: 4.0.0 Resolution: Fixed > add 0.11, 1.0, 1.1, and 2.0 streams depend

[jira] [Resolved] (KAFKA-18145) Fix failed e2e ConnectDistributedTest.test_dynamic_logging

[ https://issues.apache.org/jira/browse/KAFKA-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18145. Fix Version/s: 4.0.0 Resolution: Fixed > Fix failed e2e ConnectDistributedTest.test

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

Hi TengYao, Thanks for your response. I'll go with the consensus regarding the scope of the methods covered, when we have one. We should definitely address Producer#flush. Producer#close already has defined behaviour. Those are the most important ones. Thanks, Andrew _

Re: [DISCUSS] New "asf-committers" branch

Hi David, Yes there's a GitHub team: https://github.com/orgs/apache/teams/kafka-committers In case we still need to store the information in the repo, why do you want to put it in a separate branch and not directly in trunk? Thanks, Mickael On Wed, Dec 4, 2024 at 5:47 AM David Jacot wrote: > >

[jira] [Resolved] (KAFKA-18151) zstd-jni.jar | Why is this jar mandatory for the Kafka producer in version 3.8

[ https://issues.apache.org/jira/browse/KAFKA-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] masood resolved KAFKA-18151. Resolution: Information Provided > zstd-jni.jar | Why is this jar mandatory for the Kafka producer in vers

[jira] [Resolved] (KAFKA-16949) System test test_dynamic_logging in connect_distributed_test is failing

[ https://issues.apache.org/jira/browse/KAFKA-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16949. Resolution: Duplicate > System test test_dynamic_logging in connect_distributed_test is fa

Re: PR for README improvements - Review and Merge Request

hi Swikar I have left a comment on the PR and will review it again later thanks, chia-ping Swikar Patel 於 2024年12月4日 週三 上午7:28寫道： > Hi Team, > > I've opened a pull request to improve the Kafka README file: > > https://github.com/apache/kafka/pull/18027 > > This PR addresses KAFKA-18111 < > htt