Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.4 #141

See

[jira] [Created] (KAFKA-15029) Make ProducerIdBlock size configurable

Jeff Kim created KAFKA-15029: Summary: Make ProducerIdBlock size configurable Key: KAFKA-15029 URL: https://issues.apache.org/jira/browse/KAFKA-15029 Project: Kafka Issue Type: Task

Requesting permissions to contribute to Apache Kafka

Hello Team, I would like to contribute to the KIPs and I am requesting permission as documented here: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals#KafkaImprovementProposals-GettingStarted Wiki ID: mehbey Jira ID: mehbey Thank you, Mehari

[jira] [Created] (KAFKA-15028) AddPartitionsToTxnManager metrics

Justine Olshan created KAFKA-15028: -- Summary: AddPartitionsToTxnManager metrics Key: KAFKA-15028 URL: https://issues.apache.org/jira/browse/KAFKA-15028 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15027) Implement rack aware assignment for standby tasks

Hao Li created KAFKA-15027: -- Summary: Implement rack aware assignment for standby tasks Key: KAFKA-15027 URL: https://issues.apache.org/jira/browse/KAFKA-15027 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15025) Implement min-cost flow without balancing tasks for same subtopology

Hao Li created KAFKA-15025: -- Summary: Implement min-cost flow without balancing tasks for same subtopology Key: KAFKA-15025 URL: https://issues.apache.org/jira/browse/KAFKA-15025 Project: Kafka

[jira] [Created] (KAFKA-15026) Implement min-cost flow balancing tasks for same subtopology

Hao Li created KAFKA-15026: -- Summary: Implement min-cost flow balancing tasks for same subtopology Key: KAFKA-15026 URL: https://issues.apache.org/jira/browse/KAFKA-15026 Project: Kafka Issue

[jira] [Created] (KAFKA-15024) Add cost function for task/client

Hao Li created KAFKA-15024: -- Summary: Add cost function for task/client Key: KAFKA-15024 URL: https://issues.apache.org/jira/browse/KAFKA-15024 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15023) Get rack information for source topic partitions for a task

Hao Li created KAFKA-15023: -- Summary: Get rack information for source topic partitions for a task Key: KAFKA-15023 URL: https://issues.apache.org/jira/browse/KAFKA-15023 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15022) Support rack aware task assignment in Kafka streams

Hao Li created KAFKA-15022: -- Summary: Support rack aware task assignment in Kafka streams Key: KAFKA-15022 URL: https://issues.apache.org/jira/browse/KAFKA-15022 Project: Kafka Issue Type:

Re: [VOTE] 3.5.0 RC0

Hey all, A contributor just pointed out a small but noticeable flaw in the implementation of KIP-581 https://cwiki.apache.org/confluence/display/KAFKA/KIP-581%3A+Value+of+optional+null+field+which+has+default+value which is planned for this release. Impact: the feature works for root values in a

[jira] [Reopened] (KAFKA-8713) [Connect] JsonConverter NULL Values are replaced by default values even in NULLABLE fields

[ https://issues.apache.org/jira/browse/KAFKA-8713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reopened KAFKA-8713: > [Connect] JsonConverter NULL Values are replaced by default values even in > NULLABLE fields >

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

See

[jira] [Created] (KAFKA-15021) KRaft controller increases leader epoch when shrinking ISR

José Armando García Sancio created KAFKA-15021: -- Summary: KRaft controller increases leader epoch when shrinking ISR Key: KAFKA-15021 URL: https://issues.apache.org/jira/browse/KAFKA-15021

Re: [DISCUSS] KIP-923: Add A Grace Period to Stream Table Join

Walker, thanks for the updates. The KIP itself reads fine (of course Victoria made good comments about some phrases), but there is a couple of things from your latest reply I don't understand, and that I still think need some more discussions. Lukas, asked about in-memory option and

Re: [DISCUSS] KIP-858: Handle JBOD broker disk failure in KRaft

Heya! 5th of June 16:30 - 17:00 UTC works for me. Best, Christo On Thu, 25 May 2023 at 15:14, Igor Soarez wrote: > Hi Divij, Christo, > > Thank you for pointing that out. > > Let's aim instead for Monday 5th of June, at the same time – 16:30-17:00 > UTC. > > Please let me know if this doesn't

Re: [DISCUSS] KIP-858: Handle JBOD broker disk failure in KRaft

Hi Divij, Christo, Thank you for pointing that out. Let's aim instead for Monday 5th of June, at the same time – 16:30-17:00 UTC. Please let me know if this doesn't work either. Best, -- Igor

Re: [DISCUSS] KIP-858: Handle JBOD broker disk failure in KRaft

Hi, Igor, Thanks for the excellent, thorough and very comprehensive KIP. Although not directly in scope of the KIP, but related to it, I would have the following question about a potential future work on disk degradation. Today, what characterises as a disk failure in Kafka is an I/O exception

Re: [DISCUSS] KIP-858: Handle JBOD broker disk failure in KRaft

Heya Igor! I don't have any concerns or suggestions for improvements at this stage - the overall approach makes sense to me! I would be quite interested in attending a call, but as Divij has pointed out the 29th of May is a public holiday, so I won't be able to make that date. If there is

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

See Changes: -- [...truncated 572471 lines...] [2023-05-25T10:34:17.775Z] [2023-05-25T10:34:17.775Z] Gradle Test Run :streams:integrationTest > Gradle Test Executor 181

[jira] [Created] (KAFKA-15020) integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor test is flaky

Atul Sharma created KAFKA-15020: --- Summary: integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor test is flaky Key: KAFKA-15020 URL: https://issues.apache.org/jira/browse/KAFKA-15020

Re: [VOTE] 3.4.1 RC2

Thanks all for helping verify the RC2. But my team member found a bug that in KRaft mode, we'll log every commit message in info level, with `handleSnapshot: xxx`. That means, in KRaft mode, the active controller log will be flooded with this message every 500ms (default no-op message commit

Re: [DISCUSS] KIP-921 OpenJDK CRaC support

Hi Divij, I have prototyped this using Quarkus Superheroes [1], a demo application consisting of several microservices that communicate with each other using both HTTP and Kafka. I wanted to add the ability to transparently checkpoint and restore this application - while the regular startup

[GitHub] [kafka-site] mimaison opened a new pull request, #516: MINOR: Add blog for 3.5.0 release

mimaison opened a new pull request, #516: URL: https://github.com/apache/kafka-site/pull/516 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe,

Re: [DISCUSS] KIP-923: Add A Grace Period to Stream Table Join

Hi Walker, thanks for your responses. That makes sense. I guess there is always the option to make the implementation more configurable later on, if users request it. Also thanks for the clarifications. From my side, the KIP is good to go. Cheers, Lucas On Wed, May 24, 2023 at 11:54 PM Victoria