Re: [DISCUSS] KIP-1000: List Client Metrics Configuration Resources

Hi, Andrew, Thanks for the reply. KIP-714 proposes to use the following command for listing metric subscriptions. kafka-client-metrics.sh --bootstrap-server $BROKERS --describe kafka-configs.sh --bootstrap-server $BROKERS --describe --entity-type client-metrics Should we use --list instead to be

Re: [VOTE] KIP-979 Allow independently stop KRaft processes

Hi everyone, With +3 binding votes (and +2 non-binding), the vote passes. *KIP-979* Allow independently stop KRaft processes is Adopted! Thank you all for your reviews and votes. Regards, Hailey On Fri, Nov 17, 2023 at 12:43 PM Hailey Ni wrote: > Thanks Justine! > > On Fri, Nov 17, 2023 at 1

Re: [VOTE] KIP-979 Allow independently stop KRaft processes

Thanks Justine! On Fri, Nov 17, 2023 at 10:40 AM Justine Olshan wrote: > Thanks Hailey for the update. +1 (binding) from me :) > > Justine > > On Thu, Nov 16, 2023 at 11:32 AM Hailey Ni > wrote: > > > Hey Justine, > > > > Thank you very much for the review. > > I've updated the KIP to add a log

KIP-962: Review of second Jira/PR before 3.7 release

Hi, As part of KIP-962 https://github.com/apache/kafka/pull/14174 got merged. I think it would be good to tackle the related jira in the same release (3.7) https://issues.apache.org/jira/browse/KAFKA-14748 https://github.com/apache/kafka/pull/14107 Thanks, Florin

Re: [VOTE] KIP-979 Allow independently stop KRaft processes

Thanks Hailey for the update. +1 (binding) from me :) Justine On Thu, Nov 16, 2023 at 11:32 AM Hailey Ni wrote: > Hey Justine, > > Thank you very much for the review. > I've updated the KIP to add a log line stating that when both flags are > given, node-id will take precedence. > > Thanks, > H

[VOTE] KIP-997 Support fetch(fromKey, toKey, from, to) to WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery

https://cwiki.apache.org/confluence/display/KAFKA/KIP-997%3A++Support+fetch%28fromKey%2C+toKey%2C+from%2C+to%29+to+WindowRangeQuery+and+unify+WindowKeyQuery+and+WindowRangeQuery -- [image: Confluent] Hanyu (Peter) Zheng he/him/his Software Engineer Intern +1 (213) 431-

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

See

Re: [DISCUSS] KIP-963: Upload and delete lag metrics in Tiered Storage

Heya all! I have updated the KIP so please have another read through when you have the time. I know we are cutting it a bit close, but I would be grateful if I could start a vote early next week in order to get this in 3.7. re: Satish 104. I envision that ideally we will compare this metric with

Re: Apache Kafka 3.6.1 release

Hi, Quick update on 3.6.1: We have 1 blocker issue left: KAFKA-15802. Once it's fixed I'll start building the first release candidate. Thanks, Mickael On Mon, Nov 13, 2023 at 6:01 PM Mickael Maison wrote: > > Hi, > > Ok, I've put together a release plan: > https://cwiki.apache.org/confluence/di

[jira] [Resolved] (KAFKA-15793) Flaky test ZkMigrationIntegrationTest.testMigrateTopicDeletions

[ https://issues.apache.org/jira/browse/KAFKA-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-15793. Resolution: Fixed > Flaky test ZkMigrationIntegrationTest.testMigrateTopicDeletions >

Re: RemoteStorageManager.fetchLogSegment - how to deal with InterruptedException?

Hi, Is there a possibility to keep fetching segments instead of cancelling the underlying request? The reason I'm asking is that with the current implementation (I'm using aiven s3 plugin) there is a possibility that consumer never make any progress if the fetch.max.wait.ms is set too low and they

Re: RemoteStorageManager.fetchLogSegment - how to deal with InterruptedException?

Hi Ivan, I've opened a relevant patch to increase the timeout to fetch data from remote storage. This will reduce the error occurrence rate: https://github.com/apache/kafka/pull/14778 I think it's better to distinguish the cases: 1) Any error that happens while reading the remote data -- this s

[jira] [Resolved] (KAFKA-15849) Fix ListGroups API when runtime partition size is zero

[ https://issues.apache.org/jira/browse/KAFKA-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15849. - Fix Version/s: 3.7.0 Reviewer: David Jacot Resolution: Fixed > Fix ListGroups AP

RemoteStorageManager.fetchLogSegment - how to deal with InterruptedException?

Hello! `RemoteStorageManager.fetchLogSegment` is called in a background thread by the broker [1]. When a fetch request times out, the associated Future is cancelled [2] and the thread is interrupted. If the InterruptedException is propagated from the `RemoteStorageManager`, it pollutes the brok

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

See

Re: [DISCUSS] KIP-1000: List Client Metrics Configuration Resources

Hi Jason, Thanks for your comments. 1) Any broker can handle this API, so admin clients will choose a node randomly. 2) I was following the RPCs for configs which support controller and broker. However, looking at all of the List… and Describe… RPCs, I see that the majority are broker-only. I ha

[VOTE] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

Hi all, Following my recent message in the discussion thread, I am opening the voting for KIP-968. Thanks for your votes in advance. Cheers, Alieh

Re: [VOTE] KIP-892: Transactional StateStores

Hi everyone, With +3 binding votes (and +1 non-binding), the vote passes. KIP-892 Transactional StateStores is Adopted! Regards, Nick On Tue, 14 Nov 2023 at 09:56, Bruno Cadonna wrote: > Hi Nick! > > Thanks a lot for the KIP! > > Looking forward to the implementation! > > +1 (binding) > > Bes

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

Hi all, Thank you for the feedback. So we agreed on no default ordering for keys and TSs. So I must provide both withAscendingXx() and with DescendingXx() for the class. Apart from that, I think we can either remove the existing constructor for the `VersionedRecord` class or follow the `Optional`