[jira] [Resolved] (KAFKA-15199) remove leading and trailing spaces from user input in release.py

[ https://issues.apache.org/jira/browse/KAFKA-15199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15199. -- Fix Version/s: 3.6.0 Resolution: Fixed > remove leading and trailing spaces from user i

[jira] [Created] (KAFKA-15217) Consider usage of Gradle toolchain to specify Java version

Divij Vaidya created KAFKA-15217: Summary: Consider usage of Gradle toolchain to specify Java version Key: KAFKA-15217 URL: https://issues.apache.org/jira/browse/KAFKA-15217 Project: Kafka Is

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi, one way to avoid the "fix the bug property" would be to provide and document an additional LegacyReplicationPolicy, but still keeping the current DefaultReplicationPolicy as replication.policy.class default value, which is basically one of the workarounds suggested in the KIP. On Tue, Jul 18,

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Federico, I like the idea of implementing `LegacyReplicationPolicy` and avoiding bug fixes properties. We can drop the idea of the property and just go ahead with introducing the `LegacyReplicationPolicy` and any user upgrade from pre-KIP-690 can use this policy instead of default and no impact

[jira] [Created] (KAFKA-15218) NPE will be thrown while deleting topic and fetch from follower concurrently

Luke Chen created KAFKA-15218: - Summary: NPE will be thrown while deleting topic and fetch from follower concurrently Key: KAFKA-15218 URL: https://issues.apache.org/jira/browse/KAFKA-15218 Project: Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2012

See Changes: -- [...truncated 393192 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > TableTableJoinIntegrationTest > [caching enabled = fa

Re: [DISCUSS] KIP-660: Pluggable ReplicaPlacer

Hi Viktor, Since the use cases targeted by this KIP are common, I plan to add support for them in the default replica placement logic instead of requiring custom implementations. This is why I retired this KIP. Feel free to take over KIP-660 or reuse parts of it if you want as I won't pursue it.

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

HI all, I'm not sure I understand the benefits of introducing a separate replication policy class, besides maybe being more readable/intuitive to users who would want to know when to use one or the other. It feels like we've swapped out a "fix the bug" property for an entire "fix the bug" class, a

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2013

See Changes: -- [...truncated 391497 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 184 > StoreQueryIntegrationTest > shouldQuerySpecificStalePa

[jira] [Created] (KAFKA-15219) Support delegation tokens in KRaft

Viktor Somogyi-Vass created KAFKA-15219: --- Summary: Support delegation tokens in KRaft Key: KAFKA-15219 URL: https://issues.apache.org/jira/browse/KAFKA-15219 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-15211) DistributedConfigTest#shouldFailWithInvalidKeySize fails when run after TestSslUtils#generate

[ https://issues.apache.org/jira/browse/KAFKA-15211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15211. - Fix Version/s: 3.6.0 Resolution: Fixed > DistributedConfigTest#shouldFailWithInvalidKeySi

[jira] [Created] (KAFKA-15220) KRaftMetadataCache returns fenced brokers from getAliveBrokerNode

David Mao created KAFKA-15220: - Summary: KRaftMetadataCache returns fenced brokers from getAliveBrokerNode Key: KAFKA-15220 URL: https://issues.apache.org/jira/browse/KAFKA-15220 Project: Kafka

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Chris, the KIP says it would be a subclass of DefaultReplicationPolicy that overrides the ReplicationPolicy.offsetSyncsTopic and ReplicationPolicy.checkpointsTopic. So, not much to maintain and it would be more intuitive, as you say. On Wed, Jul 19, 2023, 4:50 PM Chris Egerton wrote: > HI all

[GitHub] [kafka-site] mjsax commented on pull request #528: MINOR: Add statmenet about ZK deprecation to 3.5 release blog post

mjsax commented on PR #528: URL: https://github.com/apache/kafka-site/pull/528#issuecomment-1642653614 @mimaison @divijvaidya @ijuma @forlack Updated this PR, including the changes of https://github.com/apache/kafka/pull/14031 -- This is an automated message from the Apache Git Ser

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

See

FYI - Timeout waiting to lock zinc...It is currently in use by another Gradle instance

If you see CI failures with the error above, it is possible caused by recent gradle upgrade we merged at https://github.com/apache/kafka/pull/14032 I will take a look at it tomorrow and revert the commit if required. Meanwhile, if someone else gets a chance, please investigate this. -- Divij Vaid

[jira] [Resolved] (KAFKA-8690) Flakey test ConnectWorkerIntegrationTest#testAddAndRemoveWorke

[ https://issues.apache.org/jira/browse/KAFKA-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-8690. Fix Version/s: 3.6.0 Resolution: Fixed > Flakey test ConnectWorkerIntegrationTest#testAddAn

[jira] [Resolved] (KAFKA-10579) Flaky test connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy

[ https://issues.apache.org/jira/browse/KAFKA-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10579. - Resolution: Fixed > Flaky test > connect.integration.InternalTopicsIntegrationTest.testStartWhe

[jira] [Resolved] (KAFKA-12842) Failing test: org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic

[ https://issues.apache.org/jira/browse/KAFKA-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-12842. - Fix Version/s: 3.6.0 Resolution: Fixed > Failing test: > org.apache.kafka.connect.integr

Re: [DISCUSS] KIP-951: Leader discovery optimisations for the client

Luke Thanks for the interest in the KIP. But what if the consumer was fetching from the follower? We already include `PreferredReadReplica` in the fetch response. > Should we put the node info of PreferredReadReplica under this case, > instead of the leader's info? > PreferredReadReplica is the

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Federico, Ah yes, sorry about that! You're correct that this would keep the two classes in line and largely eliminate the concern I posed about porting changes to both. Still, I'm a bit hesitant, and I'm not actually certain that this alternative is more intuitive. The name isn't very descripti

[jira] [Created] (KAFKA-15221) Potential race condition between requests from rebooted followers

Calvin Liu created KAFKA-15221: -- Summary: Potential race condition between requests from rebooted followers Key: KAFKA-15221 URL: https://issues.apache.org/jira/browse/KAFKA-15221 Project: Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2015

See Changes: -- [...truncated 390530 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 > TableTableJoinIntegrationTest > [caching enabled = fal

Re: [DISCUSS] KIP-951: Leader discovery optimisations for the client

Hi, Mayank, Thanks for the KIP. I agree with others that it would be useful to see the performance results. Otherwise, just a minor comment. If we don't plan to bump up the FetchResponse version, we could just remove the reference to version 16. Jun On Wed, Jul 19, 2023 at 2:31 PM Mayank Shekhar

Re: FYI - Timeout waiting to lock zinc...It is currently in use by another Gradle instance

Hi Divij, Thanks for the info. I was trying to investigate it, but cannot find the failed CI build with the zinc error. The PR: https://github.com/apache/kafka/pull/14032 is merged in build #2013 . >From build #2013 to the latest o

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

See