Re: [DISCUSS] KIP-956: Tiered Storage Quotas

Hi Abhijeet, Thanks for the update and the explanation. I had another look, and it LGTM now! Thanks. Luke On Tue, Mar 5, 2024 at 2:50 AM Jun Rao wrote: > Hi, Abhijeet, > > Thanks for the reply. Sounds good to me. > > Jun > > > On Sat, Mar 2, 2024 at 7:40 PM Abhijeet Kumar > wrote: > > > Hi

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

See

[jira] [Created] (KAFKA-16350) StateUpdated does not init transaction after canceling task close action

Matthias J. Sax created KAFKA-16350: --- Summary: StateUpdated does not init transaction after canceling task close action Key: KAFKA-16350 URL: https://issues.apache.org/jira/browse/KAFKA-16350

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hi, Jose, Thanks for the reply. 20.1. It seems that the PreferredSuccessors field didn't get fixed. It's still there together with PreferredCandidates. +{ "name": "PreferredSuccessors", "type": "[]int32", "versions": "0", + "about": "A sorted list of preferred successors to

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

See

[jira] [Created] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

Greg Harris created KAFKA-16349: --- Summary: ShutdownableThread fails build by calling Exit with race condition Key: KAFKA-16349 URL: https://issues.apache.org/jira/browse/KAFKA-16349 Project: Kafka

Re: [DISCUSS] KIP-1024: Make the restore behavior of GlobalKTables with custom processors configureable

Hey Walker Thanks for the KIP, and congrats on the KiBiKIP ;) My main point is that I'd vote against introducing `reprocessOnRestore`. The behavior for `reprocessOnRestore = false` is just incorrect and should be removed or deprecated. If we think we need to keep the old behavior around,

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

See

[jira] [Resolved] (KAFKA-16288) Values.convertToDecimal throws ClassCastExceptions on String inputs

[ https://issues.apache.org/jira/browse/KAFKA-16288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16288. - Fix Version/s: 3.8.0 Resolution: Fixed > Values.convertToDecimal throws

Re: [VOTE] KIP-939: Support Participation in 2PC

Hi all, It is so exiting to see this KIP and know that it will greatly benefit Flink and other technologies. +1 Best regards, Martijn Op vr 1 dec 2023 om 11:07 schreef Artem Livshits > Hello, > > This is a voting thread for > >

Re: [DISCUSS] KIP-932: Queues for Kafka

Hi Andrew, Thanks for the updated KIP. Few queries below: 1. What is the use-case of deliveryCount in ShareFetchResponse? 2. During delete share groups, Do we need to clean any in-memory state from share-partition leaders? 3. Any metrics for the share-coordinator? Thanks Manikumar On Wed, Feb

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hi Jun, See my comments below. On Tue, Mar 5, 2024 at 2:57 PM Jun Rao wrote: > 37. We don't batch multiple topic partitions in AddVoter, RemoveVoter and > UpdateVoter requests while other requests like Vote and BeginQuorumEpoch > support batching. Should we make them consistent? Originally I

Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker

+1 (binding) Thanks for the KIP. On Sun, Nov 19, 2023, 10:28 PM Krishna Agarwal wrote: > Hi, > I'd like to call a vote on KIP-974 which aims to publish a docker image for > GraalVM based Native Kafka Broker. > > KIP - > >

Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker

Hi, We have received 2 binding and 1 non-binding votes in the favour of this KIP. We're still in need of additional votes to move this proposal forward. If you haven't had the opportunity to review the KIP yet, I kindly encourage you to take a moment to do so and share your valuable vote. Your

Re: [DISCUSS] KIP-1021: Allow to get last stable offset (LSO) in kafka-get-offsets.sh

Hi Ahmed, Looks good to me with one remaining comment. You’ve used: bin/kafka-get-offsets.sh … --time -1 --isolation -committed bin/kafka-get-offsets.sh … --time latest --isolation -committed bin/kafka-get-offsets.sh … --time -1 --isolation -uncommitted bin/kafka-get-offsets.sh … --time

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #103

See

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

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #146

See

[jira] [Created] (KAFKA-16348) Fix flaky TopicCommandIntegrationTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

Chia-Ping Tsai created KAFKA-16348: -- Summary: Fix flaky TopicCommandIntegrationTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress Key: KAFKA-16348 URL:

[jira] [Resolved] (KAFKA-16322) Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1

[ https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16322. Fix Version/s: 3.8.0 Resolution: Fixed > Fix CVE-2023-50572 by updating jline from

Re: [DISCUSS] Apache Kafka 3.8.0 release

Hi all, Thanks for your support. I updated the skeleton release plan created by Colin. You can find it here: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.8.0 Our last release stumbled upon some problems while releasing and was delayed by several weeks, so I won't try to shave

[jira] [Resolved] (KAFKA-16252) Maligned Metrics formatting

[ https://issues.apache.org/jira/browse/KAFKA-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16252. Resolution: Fixed > Maligned Metrics formatting > --- > >

Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors

Hi Yash, Thanks for the follow-up, I like the benefits it's yielded. I too think "offsets_status" would be a better name for the response field. @Ashwin--thoughts? Cheers, Chris On Wed, Mar 6, 2024, 03:08 Ashwin wrote: > Thanks Yash, > > Yes , I think we can use

[jira] [Resolved] (KAFKA-16347) Bump ZooKeeper to 3.8.4

[ https://issues.apache.org/jira/browse/KAFKA-16347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16347. Resolution: Fixed [~kevinztw] thanks for this contribution! > Bump ZooKeeper to 3.8.4 >

Re: [DISCUSS] KIP-1024: Make the restore behavior of GlobalKTables with custom processors configureable

Hi Walker, Thanks for the KIP! Great that you are going to fix this long-standing issue! 1. I was wondering if we need the timestamp extractor as well as the key and value deserializer in Topology#addGlobalStore() that do not take a ProcessorSupplier? What about Consumed in

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

See Changes: -- [...truncated 357625 lines...] [2024-03-06T08:13:36.479Z] Gradle Test Run :core:test > Gradle Test Executor 95 > ZkMigrationClientTest > testEmptyWrite()

[jira] [Created] (KAFKA-16347) Bump ZooKeeper to 3.8.4

Mickael Maison created KAFKA-16347: -- Summary: Bump ZooKeeper to 3.8.4 Key: KAFKA-16347 URL: https://issues.apache.org/jira/browse/KAFKA-16347 Project: Kafka Issue Type: Bug Affects