[jira] [Resolved] (KAFKA-15139) Optimize the performance of `Set.removeAll(List)` in `MirrorCheckpointConnector`

[ https://issues.apache.org/jira/browse/KAFKA-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hudeqi resolved KAFKA-15139. Resolution: Fixed > Optimize the performance of `Set.removeAll(List)` in > `MirrorCheckpointConnector` >

Re: Permissions for contributing to Kafka

Hi Zixuan, Your accounts are all set. Thanks. Luke On Tue, Jul 11, 2023 at 10:54 AM Zixuan Bai wrote: > Hi master, > > Could you help grant me permissions to contribute to Kafka? > > Wiki ID: zixuan.bai > Jira ID: zixuan.bai > > Thanks a lot! > > Best regards, >

Permissions for contributing to Kafka

Hi master, Could you help grant me permissions to contribute to Kafka? Wiki ID: zixuan.bai Jira ID: zixuan.bai Thanks a lot! Best regards,

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

See

Re: wiki id

Appreciated, Luke On Tue, 11 Jul 2023 at 11:59 am, Luke Chen wrote: > Hi Willma, > > Your accounts are all set. > > Thank you. > Luke > > > > On Tue, Jul 11, 2023 at 9:21 AM Willma wrote: > > > Hi team, I have signed up for a wiki id under the email " > > phuctran3...@gmail.com", I have also

Re: wiki id

Hi Willma, Your accounts are all set. Thank you. Luke On Tue, Jul 11, 2023 at 9:21 AM Willma wrote: > Hi team, I have signed up for a wiki id under the email " > phuctran3...@gmail.com", I have also requested for a jira id under the > same > email, if possible can the team approve it?

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! Luke On Tue, Jul 11, 2023 at 8:19 AM Matthew de Detrich wrote: > Congratulations, well deserved! > > On Mon, Jul 10, 2023 at 5:45 PM Chris Egerton wrote: > > > Hi all, > > > > The PMC for Apache Kafka has invited Greg Harris to become a committer, > and > > we are happy to

wiki id

Hi team, I have signed up for a wiki id under the email " phuctran3...@gmail.com", I have also requested for a jira id under the same email, if possible can the team approve it? Thanks

Re: [VOTE] KIP-941 Range queries to accept null lower and upper bounds

Thanks for the KIP! +1 (binding) On Mon, Jul 10, 2023 at 4:30 PM Matthias J. Sax wrote: > +1 (binding) > > On 7/10/23 12:13 PM, Bill Bejeck wrote: > > Hi Lucia, > > > > Thanks for the KIP! It will be a welcomed improvement. > > > > +1(binding) > > > > -Bill > > > > On Mon, Jul 10, 2023 at 2:40 

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations, well deserved! On Mon, Jul 10, 2023 at 5:45 PM Chris Egerton wrote: > Hi all, > > The PMC for Apache Kafka has invited Greg Harris to become a committer, and > we are happy to announce that he has accepted! > > Greg has been contributing to Kafka since 2019. He has made over 50

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

See

Re: [VOTE] KIP-941 Range queries to accept null lower and upper bounds

+1 (binding) On 7/10/23 12:13 PM, Bill Bejeck wrote: Hi Lucia, Thanks for the KIP! It will be a welcomed improvement. +1(binding) -Bill On Mon, Jul 10, 2023 at 2:40 PM Lucia Cerchie wrote: Hello everyone, I'd like to call a vote on KIP-941 <

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

There is another detail about EOS that is important I guess. Messages written into topic-partitions, are only marked as "transactional", but when we commit (or abort), we only write an additional "tx marker" into the partition (the original message is not touched). If we deliver "pending"

Re: Testing FixedKeyProcessor implementation using unit tests

Not sure right now, but could be a bug. Can you maybe share the full stack trace and the test program? -Matthias On 7/10/23 3:47 AM, EXT.Zlatibor.Veljkovic wrote: Hi, I am using kafka-streams-test-utils and have problem with testing FixedKeyProcessor [KIP-820

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Hi all, It's been a few days so I went ahead with editing the KIP, the main change is on the method name https://cwiki.apache.org/confluence/display/KAFKA/KIP-759%3A+Unneeded+repartition+canceling. I will follow up with a VOTE separately. Best, Shay On Thu, Jun 29, 2023 at 4:52 PM Matthias J.

[jira] [Created] (KAFKA-15175) Assess the use of nio2 asynchronous channel for KafkaConsumer

Philip Nee created KAFKA-15175: -- Summary: Assess the use of nio2 asynchronous channel for KafkaConsumer Key: KAFKA-15175 URL: https://issues.apache.org/jira/browse/KAFKA-15175 Project: Kafka

Re: KafkaConsumer refactor proposal

Hey Divij, Sorry for the late reply - I was away for some extended period of time, but I'm back to address some of the questions here. To your point, we will incorporate your suggestions to the 1-pager, and well as the future KIP-945 (we decided to create a kip for this work for better

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.5 #32

See

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

See

[jira] [Created] (KAFKA-15174) Ensure the correct thread is executing the callbacks

Philip Nee created KAFKA-15174: -- Summary: Ensure the correct thread is executing the callbacks Key: KAFKA-15174 URL: https://issues.apache.org/jira/browse/KAFKA-15174 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15173) ApplicationEventQueue and BackgroundEventQueue should be bounded

Philip Nee created KAFKA-15173: -- Summary: ApplicationEventQueue and BackgroundEventQueue should be bounded Key: KAFKA-15173 URL: https://issues.apache.org/jira/browse/KAFKA-15173 Project: Kafka

Re: [VOTE] KIP-941 Range queries to accept null lower and upper bounds

Hi Lucia, Thanks for the KIP! It will be a welcomed improvement. +1(binding) -Bill On Mon, Jul 10, 2023 at 2:40 PM Lucia Cerchie wrote: > Hello everyone, > > I'd like to call a vote on KIP-941 > < >

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg! Xinli Shang | Tech Manager at Uber Data Kafka On Mon, Jul 10, 2023 at 9:57 AM Satish Duggana wrote: > Congratulations Greg! > > On Mon, 10 Jul 2023 at 22:19, Justine Olshan > wrote: > > > > Congrats Greg! > > > > On Mon, Jul 10, 2023 at 9:40 AM Tom Bentley > wrote: > >

[VOTE] KIP-941 Range queries to accept null lower and upper bounds

Hello everyone, I'd like to call a vote on KIP-941 . It has been under discussion since June 26, and has received edits to the KIP and approval by discussion participants. Best,

[jira] [Created] (KAFKA-15172) Allow exact mirroring of ACLs between clusters

Mickael Maison created KAFKA-15172: -- Summary: Allow exact mirroring of ACLs between clusters Key: KAFKA-15172 URL: https://issues.apache.org/jira/browse/KAFKA-15172 Project: Kafka Issue

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #31

See Changes: -- [...truncated 578086 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > StoreQueryIntegrationTest >

RE: [DISCUSS] KIP-942: Add Power(ppc64le) support

Hi Colin and Mickael, Yes I agree we don't have to run on every build , may be as mentioned we can run the job once/twice a day at specific time. According the test plan the tests which I mentioned are not specific to ppc64le , I was running tests on the trunk branch which were common across

[jira] [Resolved] (KAFKA-14059) Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest

[ https://issues.apache.org/jira/browse/KAFKA-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14059. --- Resolution: Done > Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest >

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg! On Mon, 10 Jul 2023 at 22:19, Justine Olshan wrote: > > Congrats Greg! > > On Mon, Jul 10, 2023 at 9:40 AM Tom Bentley wrote: > > > Congratulations! > > > > On Mon, 10 Jul 2023 at 17:32, wrote: > > > > > Congrats Greg! > > > > > > - > > > Gaurav > > > > > > > On 10 Jul

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! On Mon, Jul 10, 2023 at 9:40 AM Tom Bentley wrote: > Congratulations! > > On Mon, 10 Jul 2023 at 17:32, wrote: > > > Congrats Greg! > > > > - > > Gaurav > > > > > On 10 Jul 2023, at 17:25, Hector Geraldino (BLOOMBERG/ 919 3RD A) < > > hgerald...@bloomberg.net> wrote: > > > > > >

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations! On Mon, 10 Jul 2023 at 17:32, wrote: > Congrats Greg! > > - > Gaurav > > > On 10 Jul 2023, at 17:25, Hector Geraldino (BLOOMBERG/ 919 3RD A) < > hgerald...@bloomberg.net> wrote: > > > > Congrats Greg! Well deserved > > > > From: dev@kafka.apache.org At: 07/10/23 12:18:48

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Omnia, Thanks for taking this on! I have some thoughts but the general approach looks good. 1. Default value One thing I'm wrestling with is what the default value of the new property should be. I know on the Jira ticket I proposed that it should be false, but I'm having second thoughts.

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! - Gaurav > On 10 Jul 2023, at 17:25, Hector Geraldino (BLOOMBERG/ 919 3RD A) > wrote: > > Congrats Greg! Well deserved > > From: dev@kafka.apache.org At: 07/10/23 12:18:48 UTC-4:00To: > dev@kafka.apache.org > Subject: Re: [ANNOUNCE] New committer: Greg Harris > >

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! Well deserved From: dev@kafka.apache.org At: 07/10/23 12:18:48 UTC-4:00To: dev@kafka.apache.org Subject: Re: [ANNOUNCE] New committer: Greg Harris Congratulations! On Mon, Jul 10, 2023 at 9:17 AM Randall Hauch wrote: > > Congratulations, Greg. > > On Mon, Jul 10, 2023 at 11:13 

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations! On Mon, Jul 10, 2023 at 9:17 AM Randall Hauch wrote: > > Congratulations, Greg. > > On Mon, Jul 10, 2023 at 11:13 AM Mickael Maison > wrote: > > > Congratulations Greg! > > > > On Mon, Jul 10, 2023 at 6:08 PM Bill Bejeck > > wrote: > > > > > > Congrats Greg! > > > > > > -Bill

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations, Greg. On Mon, Jul 10, 2023 at 11:13 AM Mickael Maison wrote: > Congratulations Greg! > > On Mon, Jul 10, 2023 at 6:08 PM Bill Bejeck > wrote: > > > > Congrats Greg! > > > > -Bill > > > > On Mon, Jul 10, 2023 at 11:53 AM Divij Vaidya > > wrote: > > > > > Congratulations Greg!

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg! On Mon, Jul 10, 2023 at 6:08 PM Bill Bejeck wrote: > > Congrats Greg! > > -Bill > > On Mon, Jul 10, 2023 at 11:53 AM Divij Vaidya > wrote: > > > Congratulations Greg! I am going through a new committer teething process > > right now and would be happy to get you up to

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! -Bill On Mon, Jul 10, 2023 at 11:53 AM Divij Vaidya wrote: > Congratulations Greg! I am going through a new committer teething process > right now and would be happy to get you up to speed. Looking forward to > working with you in your new role. > > -- > Divij Vaidya > > > > On

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! On Mon, Jul 10, 2023 at 10:55 AM Viktor Somogyi-Vass wrote: > Congrats Greg! > > On Mon, Jul 10, 2023, 17:54 Yash Mayya wrote: > > > Congrats Greg! > > > > On Mon, Jul 10, 2023 at 9:15 PM Chris Egerton > wrote: > > > > > Hi all, > > > > > > The PMC for Apache Kafka has invited

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! On Mon, Jul 10, 2023, 17:54 Yash Mayya wrote: > Congrats Greg! > > On Mon, Jul 10, 2023 at 9:15 PM Chris Egerton wrote: > > > Hi all, > > > > The PMC for Apache Kafka has invited Greg Harris to become a committer, > and > > we are happy to announce that he has accepted! > > > >

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! On Mon, Jul 10, 2023 at 9:15 PM Chris Egerton wrote: > Hi all, > > The PMC for Apache Kafka has invited Greg Harris to become a committer, and > we are happy to announce that he has accepted! > > Greg has been contributing to Kafka since 2019. He has made over 50 commits > mostly

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg! I am going through a new committer teething process right now and would be happy to get you up to speed. Looking forward to working with you in your new role. -- Divij Vaidya On Mon, Jul 10, 2023 at 5:51 PM Josep Prat wrote: > Congrats Greg! > > > ——— > Josep Prat > >

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg! Best, Bruno On 10.07.23 17:47, Matthias J. Sax wrote: Congrats! On 7/10/23 8:45 AM, Chris Egerton wrote: Hi all, The PMC for Apache Kafka has invited Greg Harris to become a committer, and we are happy to announce that he has accepted! Greg has been contributing to

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! ——— Josep Prat Aiven Deutschland GmbH Alexanderufer 3-7, 10117 Berlin Amtsgericht Charlottenburg, HRB 209739 B Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen m: +491715557497 w: aiven.io e: josep.p...@aiven.io On Mon, Jul 10, 2023, 17:47 Matthias J. Sax wrote: >

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

See Changes: -- [...truncated 385734 lines...] [INFO] Installing /home/jenkins/workspace/Kafka_kafka_trunk/streams/quickstart/pom.xml to

Re: [ANNOUNCE] New committer: Greg Harris

Congrats! On 7/10/23 8:45 AM, Chris Egerton wrote: Hi all, The PMC for Apache Kafka has invited Greg Harris to become a committer, and we are happy to announce that he has accepted! Greg has been contributing to Kafka since 2019. He has made over 50 commits mostly around Kafka Connect and

Re: [DISCUSS] KIP-917: Additional custom metadata for remote log segment

Hi! For those who are interested, I submitted the PR with the implementation: https://github.com/apache/kafka/pull/13984 Thanks! Ivan On Tue, 13 Jun 2023 at 15:05, Ivan Yurchenko wrote: > Hi Satish, > > I understand your point and I agree with it. TBH, I didn't take into > account the

[ANNOUNCE] New committer: Greg Harris

Hi all, The PMC for Apache Kafka has invited Greg Harris to become a committer, and we are happy to announce that he has accepted! Greg has been contributing to Kafka since 2019. He has made over 50 commits mostly around Kafka Connect and Mirror Maker 2. His most notable contributions include

[GitHub] [kafka-site] divijvaidya merged pull request #532: MINOR: Add Divij PGP public keys

divijvaidya merged PR #532: URL: https://github.com/apache/kafka-site/pull/532 -- 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, e-mail:

Re: [DISCUSS] Release plan for Apache Kafka 3.5.1 release

Hi David, There is no reason to wait 3 months - we often would release 4-6 weeks after the .0 in the past. If someone is willing to volunteer to do the release and there are important bugs, it's actually better to release more often. Ismael On Mon, Jul 3, 2023 at 5:00 AM David Jacot wrote: >

[VOTE] KIP-916: MM2 distributed mode flow log context

Hello everyone, I would like to start a vote on KIP-916: MM2 distributed mode flow log context. The KIP aims to improve the logging of MM2 distributed mode. It is a relatively small change, but it has a big impact, as the current logs are very hard to decipher. (The current logs are based on the

Re: [DISCUSS] Release plan for Apache Kafka 3.5.1 release

Hey folks I am postponing the release for first RC by one day to 11th July so that we can merge in minor dependency upgrades - https://issues.apache.org/jira/browse/KAFKA-15159 -- Divij Vaidya On Mon, Jul 3, 2023 at 2:38 PM Divij Vaidya wrote: > Satish - Thank you for catching that. It is

Re: [REVIEW REQUEST] KAFKA-14591 DeleteRecordsCommand moved to tools

Fixed all comments and checkstyle issues. Please, make one more round of review. > 10 июля 2023 г., в 16:17, Federico Valeri написал(а): > > HI Nikolay, I did the review. > > Thanks again for working on this. > > Br > Fede > > On Mon, Jul 10, 2023 at 12:08 PM Николай Ижиков wrote: >> >>

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

Hi Colin, Thanks for your questions. Please have a look at my answers below. > In the previous email I asked, "who is responsible for assigning replicas to > broker directories?" Can you clarify what the answer is to that? If the > answer is the controller, there is no need for an "unknown"

[GitHub] [kafka-site] divijvaidya opened a new pull request, #532: MINOR: Add Divij PGP public keys

divijvaidya opened a new pull request, #532: URL: https://github.com/apache/kafka-site/pull/532 ## Motivation Required for 3.5.1 release ## Public keys At public server: https://keys.openpgp.org/search?q=divijv%40apache.org At Apache homepage:

Re: [VOTE] KIP-917: Additional custom metadata for remote log segment

Hi all, For your information: while developing this, I made a couple of minor changes to the KIP: 1. `nullableVersions` was added to the `CustomMetadata` schema. 2. `CustomMetadata` was made `null` by default. 3. The same changes as discussed for `RemoteLogSegmentMetadataRecord` were added for

Re: [REVIEW REQUEST] KAFKA-14591 DeleteRecordsCommand moved to tools

HI Nikolay, I did the review. Thanks again for working on this. Br Fede On Mon, Jul 10, 2023 at 12:08 PM Николай Ижиков wrote: > > Hello. > > I prepared PR [1] for ticket [2]. > DeleteRecordsCommand rewritten in java and moved to tools module. > Currently, commands doesn’t have any tests so PR

[jira] [Created] (KAFKA-15171) Kafka client poll never notifies when broker is down.

Kartik created KAFKA-15171: -- Summary: Kafka client poll never notifies when broker is down. Key: KAFKA-15171 URL: https://issues.apache.org/jira/browse/KAFKA-15171 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-882: Kafka Connect REST API timeout improvements

Hi all, I just wanted to post an update on this KIP since it has been dormant for a while now. The original issue that motivated this KIP was resolved by tweaking some configurations for the client that the connector was using to talk to the external system. Instead of discarding this KIP,

[jira] [Created] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly

li xiangyuan created KAFKA-15170: Summary: CooperativeStickyAssignor cannot adjust assignment correctly Key: KAFKA-15170 URL: https://issues.apache.org/jira/browse/KAFKA-15170 Project: Kafka

Re: [DISCUSS] KIP-948: Allow custom prefix for internal topic names in Kafka Streams

Hi Igor, Thanks for the KIP! 1. Could you please elaborate why prefixing the application.id with the team's topic namespace is not always desirable. I would like to better understand the motivation of this KIP. 2. Could you please add type and default value for the proposed config

Testing FixedKeyProcessor implementation using unit tests

Hi, I am using kafka-streams-test-utils and have problem with testing FixedKeyProcessor [KIP-820 https://cwiki.apache.org/confluence/display/KAFKA/KIP-820%3A+Extend+KStream+process+with+new+Processor+API#KIP820:ExtendKStreamprocesswithnewProcessorAPI-InfrastructureforFixedKeyRecords]. Using

[REVIEW REQUEST] KAFKA-14591 DeleteRecordsCommand moved to tools

Hello. I prepared PR [1] for ticket [2]. DeleteRecordsCommand rewritten in java and moved to tools module. Currently, commands doesn’t have any tests so PR adds some tests, also. Please, review. [1] https://github.com/apache/kafka/pull/13278 [2] https://issues.apache.org/jira/browse/KAFKA-14591

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

Yes, I think it's clear now, thank you. I agree that allowing reading behind the LSO would require more work on the broker side (we would need 1 more state for the messages, and transition when the LSO moves forward), but I don't see the extra complexity on the consumer side. Based on the KIP so

[jira] [Resolved] (KAFKA-14828) Remove R/W lock from StandardAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-14828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Purshotam Chauhan resolved KAFKA-14828. --- Fix Version/s: 3.6.0 Reviewer: Manikumar Reddy Resolution: Fixed >