Re: [DISCUSS] KIP-747 Add support for basic aggregation APIs

On Mon, Aug 16, 2021 at 5:28 PM Matthias J. Sax wrote: > > @Mohan: > > For sum(), I actually think that the return type should be same as the > input type. In the end, sum() is a special case of reduce(). > If you define something like this as you suggested (without defining new interfaces): E

Re: Request contributor permission

Yes, I missed Matthias’s msg just now. Have confirmed this. Thanks again! > On Aug 16, 2021, at 8:20 PM, Luke Chen wrote: > > Hi Yanwen, > I think Matthias has already granted your permission to jira. > Please try to log in and see if you can assign a Kafka ticket to yourselves. > > Thanks. >

Re: Request contributor permission

Hi Yanwen, I think Matthias has already granted your permission to jira. Please try to log in and see if you can assign a Kafka ticket to yourselves. Thanks. Luke On Tue, Aug 17, 2021 at 11:15 AM Yanwen Lin wrote: > Hi Kafka team, > > Please help take a look. I’d like to contribute to Apache

Re: Request contributor permission

nvm. Just saw the message. Thanks! > On Aug 16, 2021, at 8:18 PM, Yanwen Lin wrote: > > Hi Kafka team, > > Please help take a look. I’d like to contribute to Apache Kafka and my Jira > ID is: ll1124278064 > > Thanks! > > Best, > > > >> On Aug 14, 2021, at 12:05 AM, Yanwen Lin >

Re: Request contributor permission

Hi Kafka team, Please help take a look. I’d like to contribute to Apache Kafka and my Jira ID is: ll1124278064 Thanks! Best, > On Aug 14, 2021, at 12:05 AM, Yanwen Lin wrote: > > Hi Kafka team, > > Can I ask for a contributor permission so that I can assign myself to the > Kafka Jira

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

Your point about the IQ problem is an interesting one. I missed the point that the "new key" would be a "superkey", and thus, it should always be possible to compute the original key from the superkey. (As a matter of fact, for windowed-table the windowed-key is also a superkey...) I am not sure

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Thanks for the use case details. I think it actually aligns to my proposal, especially, as you say you want to react to changes asap: if you apply an "aggregation" the result would be emitted at the end (or close) of the window, and you cannot react to changes right away. But your use case also

Re: Request contributor permission

Done. On 8/14/21 12:05 AM, Yanwen Lin wrote: > Hi Kafka team, > > Can I ask for a contributor permission so that I can assign myself to the > Kafka Jira ticket. My Jira id is: ll1124278064 > > Thanks! > > Best, > Yanwen >

Re: [DISCUSS] KIP-747 Add support for basic aggregation APIs

@Mohan: For sum(), I actually think that the return type should be same as the input type. In the end, sum() is a special case of reduce(). @Alexandre: Not sure if using a `Function` to get a `Comparable` is simpler that to implement a `Comparator`? Can you elaborate on this point? In the end,

Re: Request development permissions to Apache Kafka

You should be all set. On 8/13/21 11:22 PM, Christo NUKK wrote: > Wiki ID: christo_lolovJira ID: christo_lolov >

Re: [DISCUSS] Apache Kafka 2.8.1 release

Thanks David for running 2.8.1 release. +1 On Tue, 17 Aug 2021 at 02:05, John Roesler wrote: > Thanks, David! > > +1 from me as well. > > -John > > On Mon, 2021-08-16 at 12:00 -0400, Bill Bejeck wrote: > > Thanks for volunteering to run the release David. > > > > It's a +1 for me. > > > > Bill

[jira] [Created] (KAFKA-13208) Use TopicIdPartition instead of TopicPartition when computing the topic delta

Jose Armando Garcia Sancio created KAFKA-13208: -- Summary: Use TopicIdPartition instead of TopicPartition when computing the topic delta Key: KAFKA-13208 URL:

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

See Changes: -- [...truncated 488227 lines...] [2021-08-16T21:17:53.247Z] > Task :raft:testClasses UP-TO-DATE [2021-08-16T21:17:53.247Z] > Task :connect:json:testJar

Re: [DISCUSS] Apache Kafka 2.8.1 release

Thanks, David! +1 from me as well. -John On Mon, 2021-08-16 at 12:00 -0400, Bill Bejeck wrote: > Thanks for volunteering to run the release David. > > It's a +1 for me. > > Bill > > On Mon, Aug 16, 2021 at 1:14 AM Konstantine Karantasis < > kkaranta...@apache.org> wrote: > > > Thanks for

[GitHub] [kafka-site] kkonstantine merged pull request #366: Add public key for Konstantine Karantasis

kkonstantine merged pull request #366: URL: https://github.com/apache/kafka-site/pull/366 -- 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:

[GitHub] [kafka-site] kkonstantine commented on pull request #366: Add public key for Konstantine Karantasis

kkonstantine commented on pull request #366: URL: https://github.com/apache/kafka-site/pull/366#issuecomment-899791557 Thanks @rhauch ! -- 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

Re: [VOTE] KIP-748: Add Broker Count Metrics (restarted)

Hi Colin, Thanks for restarting this KIP. +1 (binding) Best, David Le lun. 16 août 2021 à 21:32, Colin McCabe a écrit : > Hi all, > > Two months ago we tried to vote on this minor KIP adding two new broker > metrics. However, things got busy and we weren't able to complete the vote. > Now

[VOTE] KIP-748: Add Broker Count Metrics (restarted)

Hi all, Two months ago we tried to vote on this minor KIP adding two new broker metrics. However, things got busy and we weren't able to complete the vote. Now that things have quieted down a bit, let's restart the vote! Note that I made some minor changes to the KIP after some offline

[GitHub] [kafka-site] kkonstantine opened a new pull request #366: Add public key for Konstantine Karantasis

kkonstantine opened a new pull request #366: URL: https://github.com/apache/kafka-site/pull/366 Available at: https://keys.openpgp.org/search?q=kkaranta...@apache.org -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Created] (KAFKA-13207) Replica fetcher should not update partition state on diverging epoch if partition removed from fetcher

Rajini Sivaram created KAFKA-13207: -- Summary: Replica fetcher should not update partition state on diverging epoch if partition removed from fetcher Key: KAFKA-13207 URL:

[jira] [Created] (KAFKA-13206) shutting down broker needs to stop fetching as a follower in KRaft mode

Jun Rao created KAFKA-13206: --- Summary: shutting down broker needs to stop fetching as a follower in KRaft mode Key: KAFKA-13206 URL: https://issues.apache.org/jira/browse/KAFKA-13206 Project: Kafka

Re: [VOTE] KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

Thanks Gwen. Can I get one more +1 binding for the KIP? On Mon, Aug 2, 2021 at 2:51 AM Gwen Shapira wrote: > +1 (binding). Thank you for your patience and clear explanations, Omnia. > > On Mon, Jul 26, 2021 at 3:39 PM Omnia Ibrahim > wrote: > > > Bumping up this voting thread. > > > > On Fri,

Re: [DISCUSS] Apache Kafka 2.8.1 release

Thanks for volunteering to run the release David. It's a +1 for me. Bill On Mon, Aug 16, 2021 at 1:14 AM Konstantine Karantasis < kkaranta...@apache.org> wrote: > Thanks for volunteering David! +1. > > Konstantine > > On Thu, Aug 12, 2021 at 1:00 AM David Jacot > wrote: > > > Hi, > > > > I'd

[jira] [Created] (KAFKA-13205) Clarify API specification of Kafka Connect endpoint

Jonathan Kaleve created KAFKA-13205: --- Summary: Clarify API specification of Kafka Connect endpoint Key: KAFKA-13205 URL: https://issues.apache.org/jira/browse/KAFKA-13205 Project: Kafka

[jira] [Created] (KAFKA-13204) wrong assignor selected if the assignor name is identical

Luke Chen created KAFKA-13204: - Summary: wrong assignor selected if the assignor name is identical Key: KAFKA-13204 URL: https://issues.apache.org/jira/browse/KAFKA-13204 Project: Kafka Issue

Kafka Issue

Hi Kafka Dev Team, We are requesting on your help about on our encountered issue about kafka. Please see below screenshot of error. It says partition does not exist but on our event hub it is active. [cid:image002.png@01D792AA.4A6BBFB0] [cid:image003.png@01D792AA.834C99D0] Hoping for your