Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

Thanks Bruno, Marking this as accepted. Thanks everyone for their comments/feedback. Thanks! Sagar. On Mon, Sep 12, 2022 at 1:53 PM Bruno Cadonna wrote: > Hi Sagar, > > Thanks for the update and the PR! > > +1 (binding) > > Best, > Bruno > > On 10.09.22 18:57, Sagar wrote: > > Hi Bruno, > >

Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors

Pressed send to soon. Updating subject. On Mon, 12 Sept 2022 at 11:45, Jorge Esteban Quilcate Otoya < quilcate.jo...@gmail.com> wrote: > Hi everyone, > > Thank you all for the positive discussion about KIP-864. > > I would like to start a voting thread, to introduce these new metrics for >

[jira] [Created] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

Pritam Kumar created KAFKA-14220: Summary: "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing. Key: KAFKA-14220 URL:

Re: [DISCUSS] KIP-848: The Next Generation of the Consumer Rebalance Protocol

Hi Hector, We definitely need to share internals with Connect APIs. That model would not scale otherwise. Regarding the schema registry, I wonder if we could just use the new protocol. At the end of the day, the schema registry wants to elect a single writer for a partition and the owner of the

Re: [DISCUSS] KIP-848: The Next Generation of the Consumer Rebalance Protocol

Hi Guozhang, 1. I have added a reference to the relevant chapter instead of repeating the whole thing. Does that work for you? 2. The "Rebalance Triggers" section you are referring to is about when a rebalance should be triggered for the non-upgraded members using the old protocol. The section

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

Hi Sagar, Thanks for the update and the PR! +1 (binding) Best, Bruno On 10.09.22 18:57, Sagar wrote: Hi Bruno, Thanks, I think these changes make sense to me. I have updated the KIP accordingly. Thanks! Sagar. On Wed, Sep 7, 2022 at 2:16 PM Bruno Cadonna wrote: Hi Sagar, I would not

Re: Hosting Kafka Videos on ASF YouTube channel

Hi Joe Thanks for that. I'm working with our media team now, stay tuned, I'll get back to you when I have them and the location for you to get access. -Bill On Wed, Sep 7, 2022 at 10:08 AM Joe Brockmeier wrote: > Hi Bill, all, > > Next steps would be to get the videos ready for posting + we

[VOTE]

Hi everyone, Thank you all for the positive discussion about KIP-864. I would like to start a voting thread, to introduce these new metrics for Connector tasks KIP: https://cwiki.apache.org/confluence/x/6I5rDQ Thanks, Jorge

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

Hey Guozhang, Great suggestion, I made the change. Best, Vicky On Fri, Sep 9, 2022 at 10:43 PM Guozhang Wang wrote: > Thanks Vicky, that reads much clearer now. > > Just regarding the value string name itself: "self.join" may be confusing > compared to other values that people would think

[jira] [Created] (KAFKA-14221) Update Apache Kafka JVM version in CI to latest versions

Matthew de Detrich created KAFKA-14221: -- Summary: Update Apache Kafka JVM version in CI to latest versions Key: KAFKA-14221 URL: https://issues.apache.org/jira/browse/KAFKA-14221 Project: Kafka

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

See Changes: -- [...truncated 421264 lines...] [2022-09-12T16:39:08.886Z] StreamsAssignmentScaleTest > testStickyTaskAssignorManyStandbys PASSED

Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset

Thanks for the KIP! +1(binding) -Bill On Mon, Sep 12, 2022 at 1:39 PM Николай Ижиков wrote: > Community, please, share your vote for this KIP. > > > 9 сент. 2022 г., в 19:55, Guozhang Wang написал(а): > > > > +1. Thanks. > > > > Guozhang > > > > On Fri, Sep 9, 2022 at 9:52 AM Николай Ижиков

[jira] [Resolved] (KAFKA-14216) Remove ZK reference from org.apache.kafka.server.quota.ClientQuotaCallback javadoc

[ https://issues.apache.org/jira/browse/KAFKA-14216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-14216. -- Fix Version/s: 3.3 Reviewer: Luke Chen Resolution: Fixed > Remove ZK

Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset

+1 (binding). Thanks! On Mon, Sep 12, 2022 at 1:43 PM Bill Bejeck wrote: > Thanks for the KIP! > > +1(binding) > > -Bill > > On Mon, Sep 12, 2022 at 1:39 PM Николай Ижиков > wrote: > > > Community, please, share your vote for this KIP. > > > > > 9 сент. 2022 г., в 19:55, Guozhang Wang >

[jira] [Resolved] (KAFKA-14217) app-reset-tool.html should remove reference to --zookeeper flag that no longer exists

[ https://issues.apache.org/jira/browse/KAFKA-14217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-14217. -- Fix Version/s: 3.3 Reviewer: Luke Chen Resolution: Fixed >

Re: Hosting Kafka Videos on ASF YouTube channel

Sounds good - thanks! On Mon, Sep 12, 2022 at 9:50 AM Bill Bejeck wrote: > > Hi Joe > > Thanks for that. I'm working with our media team now, stay tuned, I'll get > back to you when I have them and the location for you to get access. > > -Bill > > On Wed, Sep 7, 2022 at 10:08 AM Joe Brockmeier

Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset

Community, please, share your vote for this KIP. > 9 сент. 2022 г., в 19:55, Guozhang Wang написал(а): > > +1. Thanks. > > Guozhang > > On Fri, Sep 9, 2022 at 9:52 AM Николай Ижиков wrote: > >> Hello. >> >> I'd like to start a vote on KIP-865 which adds support of >> —bootstrap-server

[jira] [Created] (KAFKA-14222) Exhausted BatchMemoryPool

Jose Armando Garcia Sancio created KAFKA-14222: -- Summary: Exhausted BatchMemoryPool Key: KAFKA-14222 URL: https://issues.apache.org/jira/browse/KAFKA-14222 Project: Kafka Issue

Re: [DISCUSS] KIP-848: The Next Generation of the Consumer Rebalance Protocol

Yes, I agree that leadership could be modeled after partition assignment(s). However, I can think of some expanded versions of the 'leader election' use case that exist today in Schema Registry. The advantage of creating a different 'type' that isn't necessarily tied to topics/partitions

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

See Changes: -- [...truncated 504222 lines...] [2022-09-12T19:40:33.937Z] [2022-09-12T19:40:33.937Z] FineGrainedAutoResetIntegrationTest >

Re: [DISCUSS] KIP-848: The Next Generation of the Consumer Rebalance Protocol

Hi, David, Thanks for the reply. A few more comments. 40. A member updates its assignors' reason to trigger a rebalance: What API in the consumer does the power user use to change the assignor reason? 41. partition.assignment.strategy defaults class

[jira] [Resolved] (KAFKA-14223) Update jdk_17_latest to adoptium 17.0.4+1

[ https://issues.apache.org/jira/browse/KAFKA-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew de Detrich resolved KAFKA-14223. Resolution: Invalid Created in wrong project > Update jdk_17_latest to adoptium

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

Thanks for the updates, Vicky! I've reviewed the KIP and your POC PR, and I'm +1 (binding). Thanks! -John On Mon, Sep 12, 2022, at 09:13, Vasiliki Papavasileiou wrote: > Hey Guozhang, > > Great suggestion, I made the change. > > Best, > Vicky > > On Fri, Sep 9, 2022 at 10:43 PM Guozhang Wang

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

See Changes: -- [...truncated 503910 lines...] [2022-09-13T00:24:31.027Z] [2022-09-13T00:24:31.027Z] FineGrainedAutoResetIntegrationTest >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #66

See Changes: -- [...truncated 572403 lines...] [2022-09-12T18:45:04.193Z] [2022-09-12T18:45:04.193Z] Exception: java.lang.AssertionError thrown from the

[jira] [Created] (KAFKA-14223) Update jdk_17_latest to adoptium 17.0.4+1

Matthew de Detrich created KAFKA-14223: -- Summary: Update jdk_17_latest to adoptium 17.0.4+1 Key: KAFKA-14223 URL: https://issues.apache.org/jira/browse/KAFKA-14223 Project: Kafka Issue

[jira] [Created] (KAFKA-14224) Consumer should auto-commit prior to cooperative partition revocation

Jason Gustafson created KAFKA-14224: --- Summary: Consumer should auto-commit prior to cooperative partition revocation Key: KAFKA-14224 URL: https://issues.apache.org/jira/browse/KAFKA-14224 Project:

[jira] [Resolved] (KAFKA-14215) KRaft forwarded requests have no quota enforcement

[ https://issues.apache.org/jira/browse/KAFKA-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-14215. - Resolution: Fixed > KRaft forwarded requests have no quota enforcement >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #68

See Changes: -- [...truncated 573883 lines...] [2022-09-13T02:58:55.263Z] [2022-09-13T02:58:55.263Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #69

See Changes: -- [...truncated 572967 lines...] [2022-09-13T05:41:17.740Z] [INFO] Finished at: 2022-09-13T05:41:19Z [2022-09-13T05:41:17.740Z] [INFO]

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

See Changes: -- [...truncated 504138 lines...] [2022-09-13T03:14:01.891Z] > Task :connect:api:publishToMavenLocal [2022-09-13T03:14:01.891Z] [2022-09-13T03:14:01.891Z] >

[jira] [Created] (KAFKA-14219) Kafka messages are not read in certain bytes or message count in batches when read from Spark

Madhav Madhu created KAFKA-14219: Summary: Kafka messages are not read in certain bytes or message count in batches when read from Spark Key: KAFKA-14219 URL: https://issues.apache.org/jira/browse/KAFKA-14219