[jira] [Created] (KAFKA-16886) KRaft partition reassignment failed after upgrade to 3.7.0

Luke Chen created KAFKA-16886: - Summary: KRaft partition reassignment failed after upgrade to 3.7.0 Key: KAFKA-16886 URL: https://issues.apache.org/jira/browse/KAFKA-16886 Project: Kafka Issue

[jira] [Created] (KAFKA-16887) document busy metrics value when remoteLogManager throttling

Luke Chen created KAFKA-16887: - Summary: document busy metrics value when remoteLogManager throttling Key: KAFKA-16887 URL: https://issues.apache.org/jira/browse/KAFKA-16887 Project: Kafka Issue

[jira] [Created] (KAFKA-16888) Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable

Chia-Ping Tsai created KAFKA-16888: -- Summary: Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable Key: KAFKA-16888 URL: https://issues.apache.org/jira/browse/KAFKA-16888 Project

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

See

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

See

[jira] [Resolved] (KAFKA-16664) Re-add EventAccumulator.take(timeout)

[ https://issues.apache.org/jira/browse/KAFKA-16664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16664. - Fix Version/s: 3.8.0 Resolution: Fixed > Re-add EventAccumulator.take(timeout) >

[jira] [Resolved] (KAFKA-16488) fix flaky MirrorConnectorsIntegrationExactlyOnceTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-16488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-16488. --- Resolution: Fixed > fix flaky MirrorConnectorsIntegrationExactlyOnceTest#testReplication > -

[jira] [Resolved] (KAFKA-14657) Admin.fenceProducers fails when Producer has ongoing transaction - but Producer gets fenced

[ https://issues.apache.org/jira/browse/KAFKA-14657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-14657. --- Resolution: Duplicate duplicate of https://issues.apache.org/jira/browse/KAFKA-16570 > Admi

[jira] [Resolved] (KAFKA-16888) Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable and StorageToolTest.testFormatEmptyDirectory

[ https://issues.apache.org/jira/browse/KAFKA-16888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16888. Fix Version/s: 3.9.0 Resolution: Fixed > Fix failed StorageToolTest.testFormatSucce

[jira] [Resolved] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks

[ https://issues.apache.org/jira/browse/KAFKA-16837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-16837. --- Fix Version/s: 3.9.0 Resolution: Fixed > Kafka Connect fails on update connector for

[jira] [Resolved] (KAFKA-16838) Kafka Connect loads old tasks from removed connectors

[ https://issues.apache.org/jira/browse/KAFKA-16838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-16838. --- Fix Version/s: 3.9.0 Resolution: Fixed > Kafka Connect loads old tasks from removed c

Re: [DISCUSS] Apache Kafka 3.7.1 release

Hi Justine, I'm sorry this release is delayed. A few new blockers have come up and we're working through them. Here's the release plan: https://cwiki.apache.org/confluence/display/KAFKA/Release+plan+3.7.1 Best, -- Igor

[jira] [Resolved] (KAFKA-16886) KRaft partition reassignment failed after upgrade to 3.7.0

[ https://issues.apache.org/jira/browse/KAFKA-16886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Soarez resolved KAFKA-16886. - Resolution: Fixed > KRaft partition reassignment failed after upgrade to 3.7.0 > --

[jira] [Reopened] (KAFKA-16886) KRaft partition reassignment failed after upgrade to 3.7.0

[ https://issues.apache.org/jira/browse/KAFKA-16886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Soarez reopened KAFKA-16886: - > KRaft partition reassignment failed after upgrade to 3.7.0 >

[jira] [Resolved] (KAFKA-16583) Update from 3.4.0 to 3.7.0 image write failed in Kraft mode

[ https://issues.apache.org/jira/browse/KAFKA-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Soarez resolved KAFKA-16583. - Resolution: Fixed > Update from 3.4.0 to 3.7.0 image write failed in Kraft mode > --

[jira] [Created] (KAFKA-16889) Kafka pods are not gracefully terminated

Sreelekshmi Geetha created KAFKA-16889: -- Summary: Kafka pods are not gracefully terminated Key: KAFKA-16889 URL: https://issues.apache.org/jira/browse/KAFKA-16889 Project: Kafka Issue Ty

Re: [DISCUSS] Apache Kafka 3.7.1 release

Hi Igor, No worries! I'm glad things are getting fixed! That's most important! And thanks for the release plan! Justine On Tue, Jun 4, 2024 at 7:01 AM Igor Soarez wrote: > Hi Justine, > > I'm sorry this release is delayed. A few new blockers have come up and > we're working through them. > > H

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

See Changes: -- [...truncated 389021 lines...] [2024-06-04T14:45:36.059Z] Gradle Test Run :core:test > Gradle Test Executor 97 > ZooKeeperClientTest > testZNodeChangeHandl

[DISCUSS] KIP-1043: Administration of groups

Hi, I would like to start a discussion thread on KIP-1043: Administration of groups. This KIP enhances the command-line tools to make it easier to administer groups on clusters with a variety of types of groups. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1043%3A+Administration+of+grou

[jira] [Created] (KAFKA-16890) Failing to build aux state on broker failover

Francois Visconte created KAFKA-16890: - Summary: Failing to build aux state on broker failover Key: KAFKA-16890 URL: https://issues.apache.org/jira/browse/KAFKA-16890 Project: Kafka Issue

[jira] [Created] (KAFKA-16891) KIP-1043: Administration of groups

Andrew Schofield created KAFKA-16891: Summary: KIP-1043: Administration of groups Key: KAFKA-16891 URL: https://issues.apache.org/jira/browse/KAFKA-16891 Project: Kafka Issue Type: New Fe

Re: [DISCUSS] KIP-924: customizable task assignment for Streams

Thanks for the update Sophie! On 5/31/24 3:41 PM, Sophie Blee-Goldman wrote: Hi all! Coming in with hopefully the last set of minor updates. During implementation of the new out-of-the-box assignors and the TaskAssignmentUtils which make heavy use of the new API, we determined a few quality-of-l

Re: [DISCUSS] KIP-1035: StateStore managed changelog offsets

Nick, Thanks a lot for updating the KIP. I made a pass over it. Overall LGTM. A few nits and some more minor questions: 200: nit (Javadocs for `StateStore.managesOffsets()`): This is highly recommended, if possible, to ensure that custom StateStores provide the consistency guarantees that

[jira] [Resolved] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired

[ https://issues.apache.org/jira/browse/KAFKA-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-15305. Resolution: Fixed push to trunk and 3.8 > The background thread should try to process the

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

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #168

See Changes: -- [...truncated 457064 lines...] [2024-06-04T21:33:58.013Z] Gradle Test Run :core:test > Gradle Test Executor 94 > ZkMigrationIntegrationTest > testStartZkBroke

Re: [DISCUSS] KIP-655: Add deduplication processor in kafka-streams

Ayoub, thanks for resurrecting this KIP. I think a built-in de-duplication operator will be very useful. Couple of questions: 100: `deduplicationKeySelector` Is this the best name? It might indicate that we select a "key" what is an overloaded term... Maybe we could use `Field` or `Id` o

Re: [DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

Jiang, Thanks for the KIP. I think it make sense. I agree with Sophie that the KIP writeup should be improved a little bit, with regard to public API (ie, config) which are changed. The only other idea I had to avoid this issue would be some internal change: we would introduce a new logger c

[jira] [Resolved] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing

[ https://issues.apache.org/jira/browse/KAFKA-16814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16814. --- Resolution: Fixed > KRaft broker cannot startup when `partition.metadata` is missing > -

[jira] [Resolved] (KAFKA-16843) Remove preAppendErrors from createPutCacheCallback

[ https://issues.apache.org/jira/browse/KAFKA-16843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-16843. --- Resolution: Fixed > Remove preAppendErrors from createPutCacheCallback > ---

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

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #169

See Changes: -- [...truncated 460623 lines...] [2024-06-05T01:53:15.987Z] Gradle Test Run :core:test > Gradle Test Executor 96 > ZkMigrationIntegrationTest > testMigrateTopic

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

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #170

See Changes: -- [...truncated 2825 lines...] [2024-06-05T02:03:09.419Z] [Warn] /home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.7/core/src/main/scala/kafka/utils/Implicits

[jira] [Resolved] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost

[ https://issues.apache.org/jira/browse/KAFKA-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16662. --- Fix Version/s: 3.8.0 3.7.1 Resolution: Duplicate > UnwritableMetadataExcep

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

See