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

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

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

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

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

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

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

[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

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

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

[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

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

[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

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

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

Hi Sophie, Thanks for the KIP. A very useful proposal! Some questions: 1. the staticPartition method in the interface is commented out. 2. For error handling, as you can imagine, there could be errors happening during partition expansion.That means, the operation would be (1) take long time to