[jira] [Created] (KAFKA-14351) Implement controller mutation quotas in KRaft

Colin McCabe created KAFKA-14351: Summary: Implement controller mutation quotas in KRaft Key: KAFKA-14351 URL: https://issues.apache.org/jira/browse/KAFKA-14351 Project: Kafka Issue Type: Imp

[jira] [Created] (KAFKA-14350) Support dynamically reconfiguring KRaft controller listeners

Colin McCabe created KAFKA-14350: Summary: Support dynamically reconfiguring KRaft controller listeners Key: KAFKA-14350 URL: https://issues.apache.org/jira/browse/KAFKA-14350 Project: Kafka

[jira] [Created] (KAFKA-14349) Support dynamically resizing the KRaft controller's thread pools

Colin McCabe created KAFKA-14349: Summary: Support dynamically resizing the KRaft controller's thread pools Key: KAFKA-14349 URL: https://issues.apache.org/jira/browse/KAFKA-14349 Project: Kafka

[jira] [Created] (KAFKA-14348) Consider renaming MetadataBatchProcessingTimeUs to MetadataDeltaProcessingTimeUs

Colin McCabe created KAFKA-14348: Summary: Consider renaming MetadataBatchProcessingTimeUs to MetadataDeltaProcessingTimeUs Key: KAFKA-14348 URL: https://issues.apache.org/jira/browse/KAFKA-14348 Proj

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats, Bruno! Well deserved. Le mer. 2 nov. 2022 à 06:12, Randall Hauch a écrit : > Congratulations, Bruno! > > On Tue, Nov 1, 2022 at 11:20 PM Sagar wrote: > > > Congrats Bruno! > > > > Sagar. > > > > On Wed, Nov 2, 2022 at 7:51 AM deng ziming > > wrote: > > > > > Congrats! > > > > > > --

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congratulations, Bruno! On Tue, Nov 1, 2022 at 11:20 PM Sagar wrote: > Congrats Bruno! > > Sagar. > > On Wed, Nov 2, 2022 at 7:51 AM deng ziming > wrote: > > > Congrats! > > > > -- > > Ziming > > > > > On Nov 2, 2022, at 3:36 AM, Guozhang Wang wrote: > > > > > > Hi everyone, > > > > > > I'd li

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats Bruno! Sagar. On Wed, Nov 2, 2022 at 7:51 AM deng ziming wrote: > Congrats! > > -- > Ziming > > > On Nov 2, 2022, at 3:36 AM, Guozhang Wang wrote: > > > > Hi everyone, > > > > I'd like to introduce our new Kafka PMC member, Bruno. > > > > Bruno has been a committer since April. 2021 a

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats! -- Ziming > On Nov 2, 2022, at 3:36 AM, Guozhang Wang wrote: > > Hi everyone, > > I'd like to introduce our new Kafka PMC member, Bruno. > > Bruno has been a committer since April. 2021 and has been very active in > the community. He's a key contributor to Kafka Streams, and also he

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

See

[jira] [Created] (KAFKA-14347) deleted records may be kept unexpectedly when leader changes while adding a new replica

Vincent Jiang created KAFKA-14347: - Summary: deleted records may be kept unexpectedly when leader changes while adding a new replica Key: KAFKA-14347 URL: https://issues.apache.org/jira/browse/KAFKA-14347

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Wow, congratulations! On Tue, Nov 1, 2022 at 8:55 PM Chris Egerton wrote: > > Congrats! > > On Tue, Nov 1, 2022, 15:44 Bill Bejeck wrote: > > > Congrats Bruno! Well deserved. > > > > -Bill > > > > On Tue, Nov 1, 2022 at 3:36 PM Guozhang Wang wrote: > > > > > Hi everyone, > > > > > > I'd like to

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

See

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Hi David, Thanks for the KIP. I have some questions/suggestions. 1) I see two new metrics: kafka.controller:type=KafkaController,name=MetadataType and kafka.controller:type=KafkaController,name=MigrationState. Won't the second metric already cover the cases of the first metric? Also, instead of

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats! On Tue, Nov 1, 2022, 15:44 Bill Bejeck wrote: > Congrats Bruno! Well deserved. > > -Bill > > On Tue, Nov 1, 2022 at 3:36 PM Guozhang Wang wrote: > > > Hi everyone, > > > > I'd like to introduce our new Kafka PMC member, Bruno. > > > > Bruno has been a committer since April. 2021 and h

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats Bruno! Well deserved. -Bill On Tue, Nov 1, 2022 at 3:36 PM Guozhang Wang wrote: > Hi everyone, > > I'd like to introduce our new Kafka PMC member, Bruno. > > Bruno has been a committer since April. 2021 and has been very active in > the community. He's a key contributor to Kafka Stream

[ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Hi everyone, I'd like to introduce our new Kafka PMC member, Bruno. Bruno has been a committer since April. 2021 and has been very active in the community. He's a key contributor to Kafka Streams, and also helped review a lot of horizontal improvements such as Mockito. It is my pleasure to announ

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

Hi Igor, Thanks for the KIP, I've finally managed to take an initial look. 0. You mention the command line tools (which one?) in the public interfaces section, but don't spell out how it changes -- what options are added. Reading the proposed changes it suggests that there are no changes to the s

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Hi, David, Thanks for the reply. 20/21. Regarding the new ZkMigrationReady field in ApiVersionsResponse, it seems that this is a bit intrusive since it exposes unneeded info to the clients. Another option is to add that field as part of the Fetch request. We can choose to only set that field in t

[jira] [Created] (KAFKA-14346) Remove static methods from internal Connect APIs for easier testing

Chris Egerton created KAFKA-14346: - Summary: Remove static methods from internal Connect APIs for easier testing Key: KAFKA-14346 URL: https://issues.apache.org/jira/browse/KAFKA-14346 Project: Kafka

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi all, I have more comments I'd like to make on this KIP when I have time (sorry for the delay, Yash, and thanks for your patience!), but I did want to chime in and say that I'm also not sure about overloading SinkTask::put. I share the concerns about creating an intuitive, simple API that Yash h

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi Randall, It's been a while for this one but the more I think about it, the more I feel like the current approach with a new overloaded `SinkTask::put` method might not be optimal. We're trying to fix a pretty corner case bug here (usage of topic mutating SMTs with sink connectors that do their

Re: [VOTE] KIP-869: Improve Streams State Restoration Visibility

We need this! + 1 non binding Cheers, Lucas On Tue, Nov 1, 2022 at 10:01 AM Bruno Cadonna wrote: > > Guozhang, > > Thanks for the KIP! > > +1 (binding) > > Best, > Bruno > > On 25.10.22 22:07, Walker Carlson wrote: > > +1 non binding > > > > Thanks for the kip! > > > > On Thu, Oct 20, 2022 at 1

[VOTE] KIP-852: Optimize calculation of size for log in remote tier

Hey folks The discuss thread for this KIP has been open for a few months with no concerns being surfaced. I would like to start a vote for the implementation of this KIP. The KIP is available at https://cwiki.apache.org/confluence/display/KAFKA/KIP-852%3A+Optimize+calculation+of+size+for+log+in+r

Re: [VOTE] KIP-869: Improve Streams State Restoration Visibility

Guozhang, Thanks for the KIP! +1 (binding) Best, Bruno On 25.10.22 22:07, Walker Carlson wrote: +1 non binding Thanks for the kip! On Thu, Oct 20, 2022 at 10:25 PM John Roesler wrote: Thanks for the KIP, Guozhang! I'm +1 (binding) -John On Wed, Oct 12, 2022, at 16:36, Nick Telford wro