Re: [VOTE] KIP-774: Deprecate public access to Admin client's *Result constructors

Hi Tom, Thanks for the KIP. I agree with you that we should change it back to non-public for future enhancement. +1 (non-binding) Thank you. Luke On Mon, Sep 20, 2021 at 9:05 PM Josep Prat wrote: > Hi Tom, > > Thanks for the KIP. It's a +1 (non binding) from my side. > > Best, > ——— > Josep

Re: [DISCUSS] KIP-776: Add Consumer#peek for debugging/tuning

ide any new functionality IMHO, weakening the > > motivation a bit. > > > > Additionally, for the peek() case, I believe that users may want to have > > more fine-grained exposure of records, such as from specific partitions > > instead of getting random records. It's proba

Re: Contribution help please

Hi Jon, I checked your PR. I think you didn't set the "indent" correctly. It looks like your indent setting is to 2, but we use 4. Please update the setting in IntelliJ. REF: https://www.jetbrains.com/help/idea/reformat-and-rearrange-code.html Thank you. Luke On Mon, Sep 20, 2021 at 2:47 PM Jon

[DISCUSS] KIP-776: Add Consumer#peek for debugging/tuning

Hi everyone, I'd like to discuss the following proposal to add Consumer#peek for debugging/tuning. The main purpose for Consumer#peek is to allow users: 1. peek what records existed at broker side and not increasing the position offsets. 2. throw exceptions when there is connection

Re: [DISCUSS] Apache Kafka 3.1.0 release

Thanks for volunteering! +1 (non-binding) Look forward to V3.1.0! Thank you. Luke On Sat, Sep 18, 2021 at 8:55 PM Israel Ekpo wrote: > Thanks for volunteering David. It’s great that we are already planning the > 3.1.0 release. > > > On Thu, Sep 16, 2021 at 3:38 PM Bill Bejeck wrote: > > >

[jira] [Created] (KAFKA-13309) InMemorySessionStore#fetch/backwardFetch doesn't return in correct order

Luke Chen created KAFKA-13309: - Summary: InMemorySessionStore#fetch/backwardFetch doesn't return in correct order Key: KAFKA-13309 URL: https://issues.apache.org/jira/browse/KAFKA-13309 Project: Kafka

Re: [VOTE] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Thanks for the KIP. + 1 (non-binding) Thanks. Luke On Wed, Sep 8, 2021 at 2:48 PM Josep Prat wrote: > +1 (non binding). > > Thanks for the KIP Sagar! > ——— > Josep Prat > > Aiven Deutschland GmbH > > Immanuelkirchstraße 26, 10405 Berlin > > Amtsgericht Charlottenburg, HRB 209739 B > >

Re: [VOTE] KIP-773 Differentiate consistently metric latency measured in millis and nanos

Thanks for the KIP. +1 (non-binding) Thanks. Luke On Sat, Sep 4, 2021 at 10:32 AM Guozhang Wang wrote: > Thanks Josep, > > Took a look at the KIP, LGTM. > > On Fri, Sep 3, 2021 at 11:25 AM Josep Prat > wrote: > > > Hi there, > > > > Since it's a rather small KIP, I'd like to start a vote for

[jira] [Created] (KAFKA-13264) backwardFetch in InMemoryWindowStore doesn't return in reverse order

Luke Chen created KAFKA-13264: - Summary: backwardFetch in InMemoryWindowStore doesn't return in reverse order Key: KAFKA-13264 URL: https://issues.apache.org/jira/browse/KAFKA-13264 Project: Kafka

Re: [VOTE] KIP-761: Add Total Blocked Time Metric to Streams

Thanks for the KIP. +1 (non-binding) Thank you. Luke On Wed, Sep 1, 2021 at 2:36 AM Guozhang Wang wrote: > Thanks for letting us know, Rohan. > > On Tue, Aug 31, 2021 at 1:08 AM Rohan Desai > wrote: > > > FYI I've updated the metric names in the KIP to the form > ".*-time-ns-total" > > and

Re: [DISCUSS] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Thanks for the KIP. Overall LGTM. Just one thought, if we "rename" the config directly as mentioned in the KIP, would that break existing applications? Should we deprecate the old one first, and make the old/new names co-exist for some period of time? Public Interfaces - Adding a new config

Re: [EXTERNAL] Re: Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

t; *Sent:* 01 September 2021 09:31 > *To:* Ashish Patil > *Subject:* RE: [EXTERNAL] Re: Security vulnerabilities in > kafka:2.13-2.6.0/2.7.0 docker image > > > > > > > > *From:* Luke Chen > *Sent:* 01 September 2021 04:11 > *To:* Kafka Users > *Cc:* dev@kaf

Re: Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

Hi Ashish, I suggested that you upgrade to V2.8. I checked 2 of the CVEs, and are fixed (or not used, like libfetch) in V2.8. If you still found the CVEs existed in V2.8, please raise it. Thank you. Luke On Wed, Sep 1, 2021 at 4:07 AM Ashish Patil wrote: > Hi Team > > I wanted to use the

[jira] [Created] (KAFKA-13230) port EmbeddedKafkaCluster back to auto clean up way

Luke Chen created KAFKA-13230: - Summary: port EmbeddedKafkaCluster back to auto clean up way Key: KAFKA-13230 URL: https://issues.apache.org/jira/browse/KAFKA-13230 Project: Kafka Issue Type

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

+1 (non-binding) Thanks for the KIP! Thank you. Luke On Wed, Aug 25, 2021 at 4:55 AM Jason Gustafson wrote: > Thanks Colin! +1 > > On Mon, Aug 23, 2021 at 1:37 PM David Arthur wrote: > > > Thanks, Colin. Looks good to me! > > > > +1 binding > > > > -David > > > > On Mon, Aug 16, 2021 at 3:37

Re: Kafka Issue

s > > Makati City, 1226 > > +63 2753 8865 > > > > > > *Next OOO planned: * > > > > > > *From:* Adam Bellemare > *Sent:* Thursday, 19 August 2021 9:39 pm > *To:* dev@kafka.apache.org > *Cc:* Luke Chen ; Errol Pontillas < > errol.pontil...@

Re: [VOTE] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Hi all, Thanks for the discussion and votes. The KIP passed with: 3 binding votes: Guozhang Wang Bill Bejeck John Roesler 1 non-binding votes: Luke Chen I'll close the vote and start the implementation. Thank you all. Luke On Thu, Aug 19, 2021 at 10:47 PM Bill Bejeck wrote: > Tha

Re: Kafka Issue

Hi Roel, I'm not sure if it's just me or not, but I can't see your screenshots, so I don't know what happened. Thanks. Luke On Wed, Aug 18, 2021 at 10:12 PM Jason Kamdon wrote: > Hi Team, > > > > Can we have an update regarding below concern. > > > > > > Thanks! > > > > Regards, > > [image:

Re: Failed Unit testings in ReassignPartitionsIntegrationTest

Hi Yanwen, Welcome to Kafka! Usually, we posted flaky tests on JIRA when we saw failed tests on Jenkins build, either on trunk build, or PR build. What you mentioned 2 (flaky) failed tests have not failed in Jenkins for a long time (since build # 364, check below link). Besides, it also passed in

[jira] [Created] (KAFKA-13212) findSessions queries with open endpoints for SessionStore

Luke Chen created KAFKA-13212: - Summary: findSessions queries with open endpoints for SessionStore Key: KAFKA-13212 URL: https://issues.apache.org/jira/browse/KAFKA-13212 Project: Kafka Issue

[jira] [Created] (KAFKA-13211) fetch queries with open endpoints for WindowStore

Luke Chen created KAFKA-13211: - Summary: fetch queries with open endpoints for WindowStore Key: KAFKA-13211 URL: https://issues.apache.org/jira/browse/KAFKA-13211 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-13210) fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Luke Chen created KAFKA-13210: - Summary: fetch/findSessions queries with open endpoints for SessionStore/WindowStore Key: KAFKA-13210 URL: https://issues.apache.org/jira/browse/KAFKA-13210 Project: Kafka

[VOTE] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Hi all, I'd like to start to vote for *KIP-766: fetch/findSessions queries with open endpoints for WindowStore/SessionStore*. This is a follow-up KIP for KIP-763: Range queries with open endpoints . In

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

[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

Re: [DISCUSS] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Hi all, Sorry that I found the KIP link I provided in the previous email is wrong. Updated link is as below. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186876596 Thank you. Luke On Thu, Aug 5, 2021 at 2:31 PM Luke Chen wrote: > Hi everyone, > > I'd like

[DISCUSS] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Hi everyone, I'd like to start the discussion for *KIP-766: fetch/findSessions queries with open endpoints for WindowStore/SessionStore*. This is a follow-up KIP for KIP-763: Range queries with open endpoints

[jira] [Resolved] (KAFKA-13145) Renaming the time interval window for better understanding

[ https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13145. --- Resolution: Won't Fix > Renaming the time interval window for better understand

[jira] [Created] (KAFKA-13145) Renaming the time interval window for better understanding

Luke Chen created KAFKA-13145: - Summary: Renaming the time interval window for better understanding Key: KAFKA-13145 URL: https://issues.apache.org/jira/browse/KAFKA-13145 Project: Kafka Issue

Re: [DISCUSS] KIP-765: Introduce new SlidingWindow type for [start,end] time

e > >> `KGroupedStream#windowedBy()` to allow uses to use the newly added > >> window. I don't think we can change `SlidingWindows` in a backward > >> compatible way, thus, we need to add a new class and new overloads for > >> `windowedBy()` to make the

[DISCUSS] KIP-765: Introduce new SlidingWindow type for [start,end] time

Hi, Kafka. I'd like to discuss the KIP-765: Introduce new SlidingWindow type for [start,end] time. This is an existing bug in slidingWindows, that we used the wrong window type so the window time interval will have 1 ms less at the end time. This KIP will fix this issue.

[jira] [Created] (KAFKA-13129) Fix broken system tests relate to the ConfigCommand change

Luke Chen created KAFKA-13129: - Summary: Fix broken system tests relate to the ConfigCommand change Key: KAFKA-13129 URL: https://issues.apache.org/jira/browse/KAFKA-13129 Project: Kafka Issue

[jira] [Created] (KAFKA-13125) Close KeyValueIterator implemented instance in internal tests (cont.)

Luke Chen created KAFKA-13125: - Summary: Close KeyValueIterator implemented instance in internal tests (cont.) Key: KAFKA-13125 URL: https://issues.apache.org/jira/browse/KAFKA-13125 Project: Kafka

[jira] [Created] (KAFKA-13124) Cl

Luke Chen created KAFKA-13124: - Summary: Cl Key: KAFKA-13124 URL: https://issues.apache.org/jira/browse/KAFKA-13124 Project: Kafka Issue Type: Sub-task Reporter: Luke Chen

[jira] [Created] (KAFKA-13123) Close KeyValueIterator implemented instance in example codes and some tests

Luke Chen created KAFKA-13123: - Summary: Close KeyValueIterator implemented instance in example codes and some tests Key: KAFKA-13123 URL: https://issues.apache.org/jira/browse/KAFKA-13123 Project: Kafka

[jira] [Created] (KAFKA-13122) Close KeyValueIterator implemented instance to avoid resource leak

Luke Chen created KAFKA-13122: - Summary: Close KeyValueIterator implemented instance to avoid resource leak Key: KAFKA-13122 URL: https://issues.apache.org/jira/browse/KAFKA-13122 Project: Kafka

Re: [VOTE] KIP-763: Range queries with open endpoints

Hi Patrick, I like this KIP! +1 (non-binding) Luke On Thu, Jul 22, 2021 at 7:04 AM Matthias J. Sax wrote: > Thanks for the KIP. > > +1 (binding) > > > -Matthias > > On 7/21/21 1:18 PM, Patrick Stuedi wrote: > > Hi all, > > > > Thanks for the feedback on the KIP, I have updated the KIP and

[jira] [Created] (KAFKA-13108) Improve the test coverage for ConfigCommandTest

Luke Chen created KAFKA-13108: - Summary: Improve the test coverage for ConfigCommandTest Key: KAFKA-13108 URL: https://issues.apache.org/jira/browse/KAFKA-13108 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-13072) refactor RemoveMembersFromConsumerGroupHandler

Luke Chen created KAFKA-13072: - Summary: refactor RemoveMembersFromConsumerGroupHandler Key: KAFKA-13072 URL: https://issues.apache.org/jira/browse/KAFKA-13072 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-13064) refactor ListConsumerGroupOffsetsHandler

Luke Chen created KAFKA-13064: - Summary: refactor ListConsumerGroupOffsetsHandler Key: KAFKA-13064 URL: https://issues.apache.org/jira/browse/KAFKA-13064 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-13063) refactor DescribeConsumerGroupsHandler

Luke Chen created KAFKA-13063: - Summary: refactor DescribeConsumerGroupsHandler Key: KAFKA-13063 URL: https://issues.apache.org/jira/browse/KAFKA-13063 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-13062) refactor DeleteConsumerGroupsHandler

Luke Chen created KAFKA-13062: - Summary: refactor DeleteConsumerGroupsHandler Key: KAFKA-13062 URL: https://issues.apache.org/jira/browse/KAFKA-13062 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-13059) update for DeleteConsumerGroupOffsetsHandler

Luke Chen created KAFKA-13059: - Summary: update for DeleteConsumerGroupOffsetsHandler Key: KAFKA-13059 URL: https://issues.apache.org/jira/browse/KAFKA-13059 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-12884) Remove "--zookeeper" in system tests

[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-12884. --- Resolution: Done > Remove "--zookeeper" in

[jira] [Created] (KAFKA-13046) Improve the test coverage for stickyAssignor

Luke Chen created KAFKA-13046: - Summary: Improve the test coverage for stickyAssignor Key: KAFKA-13046 URL: https://issues.apache.org/jira/browse/KAFKA-13046 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-13033) coordinator not available error should cause add into unmap list to do a new lookup

Luke Chen created KAFKA-13033: - Summary: coordinator not available error should cause add into unmap list to do a new lookup Key: KAFKA-13033 URL: https://issues.apache.org/jira/browse/KAFKA-13033

[jira] [Created] (KAFKA-13023) make "range, cooperative-sticky" as the default assignor in V3.0

Luke Chen created KAFKA-13023: - Summary: make "range, cooperative-sticky" as the default assignor in V3.0 Key: KAFKA-13023 URL: https://issues.apache.org/jira/browse/KAFKA-13023 Proj

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi Konstantine, We've decided that the KIP-726 will be released in V3.1, not V3.0. KIP-726: Make the "cooperative-sticky, range" as the default assignor Could you please remove this KIP from the 3.0 release plan wiki page? Thank you. Luke On Wed, Jun 30, 2021 at 8:23 AM Konstantine Karantasis

[jira] [Created] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

Luke Chen created KAFKA-13008: - Summary: Stream will stop processing data for a long time while waiting for the partition lag Key: KAFKA-13008 URL: https://issues.apache.org/jira/browse/KAFKA-13008

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

remain the default but any application can upgrade > > to the CooperativeStickyAssignor with just a single rolling bounce (to > > remove the "range" assignor), rather than the usual two. We can then go > > ahead and fully make the CooperativeStickyAssignor the default assignor >

Re: [ANNOUNCE] New Kafka PMC Member: Konstantine Karantasis

Congrats! Konstantine! Luke On Tue, Jun 22, 2021 at 3:23 PM Dongjin Lee wrote: > Congratulations, Konstantine! > > Best, > Dongjin > > On Tue, Jun 22, 2021 at 6:52 AM Konstantine Karantasis > wrote: > > > Thank you Mickael and everyone for the kind replies. I'm honored and > > excited to help

Re: Kafka upgrading help?

Hi, I can see in V2.4.0, we upgraded zookeeper from 3.4.14 to 3.5.5. So, I guess before V2.4.0 is good to go since it's just zookeeper minor version upgrade. But you still need to have a complete test for the upgrade. In your case, I think you can expect the new feature: KRaft mode, to remove

Re: [VOTE] KIP-726: Make the "cooperative-sticky, range" as the default assignor

(binding) > > Konstantine > > > On Wed, Jun 9, 2021 at 6:36 AM Luke Chen wrote: > > > Hi all, > > Bump this thread to see if there's anyone wants to vote or have > questions. > > > > Thank you. > > Luke > > > > Sophie Blee-Goldman 於 20

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi Ryan, Thanks for your good comments. I've listed your comments in "Rejected Alternatives" in KIP. 1. Some cooperative-sticky related defects might not free before V3.0 → We've marked important defects as blocker for V3.0, ex: KAFKA-12896. Please raise any important defect if you found any.

Re: [VOTE] KIP-726: Make the "cooperative-sticky, range" as the default assignor

Hi all, Bump this thread to see if there's anyone wants to vote or have questions. Thank you. Luke Sophie Blee-Goldman 於 2021年6月8日 週二 上午4:40 寫道： > +1 (binding) > > Thanks Luke > > On Mon, Jun 7, 2021 at 3:26 AM Luke Chen wrote: > > > Hi Ismael, > > Thanks for yo

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

remove the placeholder text from the Rejected Alternatives and > simply state that there aren't any. Unless something is worth mentioning in > that section. > > Thanks, > Konstantine > > On Tue, Jun 8, 2021 at 5:20 AM Luke Chen wrote: > > > Hi Ryan, > > Than

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

e, and if we don't then > there's no harm as it's > not going to change the behavior. > > On Wed, Jun 2, 2021 at 7:28 PM Luke Chen wrote: > > > Hi Sophie, > > Thanks for the reminder. Yes, I was thinking this KIP doesn't have to be > > put into a major release since

Re: [VOTE] KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)

Hi Ismael, Thanks for the KIP. +1 (non-binding) Thanks. Luke On Tue, Jun 8, 2021 at 7:18 AM Konstantine Karantasis wrote: > Thanks for the KIP Ismael. I agree that giving an early enough deprecation > notice for an upcoming change like this one and doing so in a major release > is best in this

Re: [VOTE] KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)

Hi Ismael, Thanks for the KIP! +1 (non-binding) Thanks. Luke On Tue, Jun 8, 2021 at 8:16 AM Israel Ekpo wrote: > I support this as well. The motivation and proposed changes makes sense to > me > > +1 (non-binding) > > On Mon, Jun 7, 2021 at 6:28 PM Satish Duggana > wrote: > > > +1

Re: [VOTE] KIP-726: Make the "cooperative-sticky, range" as the default assignor

whether two rolling bounces are > required or not. What exactly is being proposed? > > Ismael > > On Wed, Jun 2, 2021, 8:16 PM Luke Chen wrote: > > > Hi all, > > I'd like to call for a vote on KIP-726: Make the "cooperative-sticky, > > range" as th

Re: [VOTE] KIP-752: Support --bootstrap-server in ReplicaVerificationTool

Hi Dongjin, Thanks for the KIP. +1 (non-binding) Thanks. Luke On Sun, Jun 6, 2021 at 5:38 AM Dongjin Lee wrote: > Hi all, > > I'd like to call for a vote on KIP-752: Support --bootstrap-server in > ReplicaVerificationTool: > > >

Re: [VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

Hi Wenbing, Thanks for the KIP! +1 (non-binding) Thanks. Luke On Sun, Jun 6, 2021 at 8:16 AM wenbing shen wrote: > Hi all, > > I'd like to start a vote on KIP-749 to add two options (--files and > --files-separator) to ConsoleProducer. > > >

[jira] [Created] (KAFKA-12892) InvalidACLException thrown in tests caused jenkins build unstable

Luke Chen created KAFKA-12892: - Summary: InvalidACLException thrown in tests caused jenkins build unstable Key: KAFKA-12892 URL: https://issues.apache.org/jira/browse/KAFKA-12892 Project: Kafka

[jira] [Created] (KAFKA-12884) Remove "--zookeeper" in system tests

Luke Chen created KAFKA-12884: - Summary: Remove "--zookeeper" in system tests Key: KAFKA-12884 URL: https://issues.apache.org/jira/browse/KAFKA-12884 Project: Kafka Issue Type

[VOTE] KIP-726: Make the "cooperative-sticky, range" as the default assignor

Hi all, I'd like to call for a vote on KIP-726: Make the "cooperative-sticky, range" as the default assignor. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=177048248 This KIP is still waiting for the prerequisite stories to get completed, but it should be soon. Hopefully this

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

t; > > > On Mon, Apr 12, 2021 at 8:17 AM Chris Egerton > > > > > wrote: > > > > > > > > > > > Hi Sophie, > > > > > > > > > > > > This sounds fantastic. I've made a note on KAFKA-12487 about > being > > > sure > &

Re: [REVIEW REQUESTED] - Pull Requests for KIP-633 and Addition of Missing Javadocs

Hi Israel, Thanks for submitting the PR. I've reviewed those 2 PRs and left some comments there. I also see Sophie reviewed 1 of them. See if there are other guys available to review. But I'd like to suggest you look at the Contributing Code Changes

Re: [VOTE] KIP-735: Increase default consumer session timeout

Hi Jason, +1 (non-binding) Really need this KIP to save poor jenkins flaky tests. :) Luke On Thu, Apr 29, 2021 at 4:01 PM David Jacot wrote: > +1 (binding) > > Thanks for the KIP. > > On Thu, Apr 29, 2021 at 2:27 AM Bill Bejeck wrote: > > > Thanks for the KIP Jason, +1(binding) > > > > -Bill

Re: [VOTE} KIP-733: change Kafka Streams default replication factor config

Hi Matthias, +1 (non-binding) Thanks for the KIP. Luke On Fri, Apr 16, 2021 at 3:32 PM Bruno Cadonna wrote: > Thanks Matthias, > > +1 (binding) > > Best, > Bruno > > On 16.04.21 01:03, Jorge Esteban Quilcate Otoya wrote: > > +1 > > > > Thanks Matthias! > > > > On Thu, 15 Apr 2021, 20:48

Re: [ANNOUNCE] New Kafka PMC Member: Randall Hauch

Congratulations Randall! Luke Bill Bejeck 於 2021年4月17日 週六 上午11:33 寫道： > Congratulations Randall! > > -Bill > > On Fri, Apr 16, 2021 at 11:10 PM lobo xu wrote: > > > Congrats Randall > > >

Re: [VOTE] KIP-732: Deprecate eos-alpha and replace eos-beta with eos-v2

Hi Sophie, +1 (non-binding) Thanks for the KIP! Luke Matthias J. Sax 於 2021年4月16日 週五 上午11:21 寫道： > +1 (binding) > > On 4/15/21 12:56 PM, Israel Ekpo wrote: > > 1+ I agree. > > > > I think besides just merging the changes, specific attention should be > > brought to the KIP in the 3.0 release

[jira] [Created] (KAFKA-12677) The raftCluster always send to the wrong active controller and never update

Luke Chen created KAFKA-12677: - Summary: The raftCluster always send to the wrong active controller and never update Key: KAFKA-12677 URL: https://issues.apache.org/jira/browse/KAFKA-12677 Project: Kafka

[jira] [Created] (KAFKA-12676) Improve sticky general assignor underlying algorithm for the imbalanced case

Luke Chen created KAFKA-12676: - Summary: Improve sticky general assignor underlying algorithm for the imbalanced case Key: KAFKA-12676 URL: https://issues.apache.org/jira/browse/KAFKA-12676 Project

[jira] [Created] (KAFKA-12675) Improve sticky general assignor scalability and performance

Luke Chen created KAFKA-12675: - Summary: Improve sticky general assignor scalability and performance Key: KAFKA-12675 URL: https://issues.apache.org/jira/browse/KAFKA-12675 Project: Kafka Issue

[jira] [Resolved] (KAFKA-12598) Remove deprecated --zookeeper in ConfigCommand

[ https://issues.apache.org/jira/browse/KAFKA-12598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-12598. --- Fix Version/s: (was: 3.0.0) Resolution: Won't Fix > Remove deprecated --zookee

[jira] [Created] (KAFKA-12654) separate checkAllSubscriptionEqual and getConsumerToOwnedPartitions methods

Luke Chen created KAFKA-12654: - Summary: separate checkAllSubscriptionEqual and getConsumerToOwnedPartitions methods Key: KAFKA-12654 URL: https://issues.apache.org/jira/browse/KAFKA-12654 Project: Kafka

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

the user does not implement #onPartitionsLost (see > KAFKA-12638), we will throw a CommitFailedException which will be bubbled > up through poll() after completing the rebalance. The member will then > downgrade its protocol to EAGER for the next rebalance. > > Let me k

Re: [ANNOUNCE] New Committer: Bruno Cadonna

Congrats Bruno!! Luke On Thu, Apr 8, 2021 at 9:18 AM Matthias J. Sax wrote: > Congrats Bruno! Very well deserved! > > > -Matthias > > On 4/7/21 3:51 PM, Bill Bejeck wrote: > > Congrats Bruno! Well deserved. > > > > Bill > > > > On Wed, Apr 7, 2021 at 6:34 PM Guozhang Wang wrote: > > > >>

Re: [ANNOUNCE] New Kafka PMC Member: Bill Bejeck

Congratulations Bill! Luke On Thu, Apr 8, 2021 at 9:17 AM Matthias J. Sax wrote: > Hi, > > It's my pleasure to announce that Bill Bejeck in now a member of the > Kafka PMC. > > Bill has been a Kafka committer since Feb 2019. He has remained > active in the community since becoming a committer.

Re: New Jenkins job for master and release branches

Thanks Ismael! I love each JDK+Scala combination is built in parallel! Thanks. Luke On Mon, Apr 5, 2021 at 12:24 PM Gwen Shapira wrote: > W00t! This is super awesome. Thank you so much!!! > > On Sun, Apr 4, 2021 at 2:22 PM Ismael Juma wrote: > > > Hi all, > > > > As part of KAFKA-12614 < >

Re: Question on kafka connect's incremental rebalance algorithm

Hi Ahmed, I think this bug KAFKA-12495 is the issue you described, which is under code review now. If not, please open another JIRA ticket to track it. Thanks. Luke On Tue, Apr 6, 2021 at 4:18 AM Thouqueer Ahmed < thouqueer.ah...@maplelabs.com>

[jira] [Resolved] (KAFKA-12599) Remove deprecated --zookeeper in preferredReplicaLeaderElectionCommand

[ https://issues.apache.org/jira/browse/KAFKA-12599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-12599. --- Resolution: Duplicate > Remove deprecated --zookeeper in preferredReplicaLeaderElectionComm

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

ward with cooperative protocols, when: > > > 1) a new member joined the group with the old version, and hence only > > > recognized eager protocol and executing the eager protocol with its > first > > > rebalance, what would happen. > > > 2) in addition

[jira] [Created] (KAFKA-12598) Remove deprecated --zookeeper in ConfigCommand

Luke Chen created KAFKA-12598: - Summary: Remove deprecated --zookeeper in ConfigCommand Key: KAFKA-12598 URL: https://issues.apache.org/jira/browse/KAFKA-12598 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12599) Remove deprecated --zookeeper in preferredReplicaLeaderElectionCommand

Luke Chen created KAFKA-12599: - Summary: Remove deprecated --zookeeper in preferredReplicaLeaderElectionCommand Key: KAFKA-12599 URL: https://issues.apache.org/jira/browse/KAFKA-12599 Project: Kafka

[jira] [Created] (KAFKA-12597) Remove deprecated --zookeeper in ReassignPartitionsCommands

Luke Chen created KAFKA-12597: - Summary: Remove deprecated --zookeeper in ReassignPartitionsCommands Key: KAFKA-12597 URL: https://issues.apache.org/jira/browse/KAFKA-12597 Project: Kafka Issue

[jira] [Created] (KAFKA-12596) Remove deprecated --zookeeper in topicCommands

Luke Chen created KAFKA-12596: - Summary: Remove deprecated --zookeeper in topicCommands Key: KAFKA-12596 URL: https://issues.apache.org/jira/browse/KAFKA-12596 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12588) Remove deprecated --zookeeper in shell commands

Luke Chen created KAFKA-12588: - Summary: Remove deprecated --zookeeper in shell commands Key: KAFKA-12588 URL: https://issues.apache.org/jira/browse/KAFKA-12588 Project: Kafka Issue Type: Task

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

> > Let's pause this KIP while I work on making these two improvements in > > KAFKA-12477 <https://issues.apache.org/jira/browse/KAFKA-12477>. Once I > > can > > confirm the > > short-circuit and single rolling bounce will be available for 3.0, I'll > > report b

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

rote: > Thanks for the KIP. Are we saying that every consumer upgraded would have > to follow the complex path described in the KIP? Also, what happens if they > don't read the instructions and upgrade as they have in the past? > > Ismael > > On Fri, Mar 26, 2021, 1:53 AM Luke C

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

all the kinks so I wouldn't commit to a single rolling bounce > upgrade as part of > this KIP, but it's worth noting that by 3.0 we may be in an even better > position with regards > to this assignor. The ticket is > https://issues.apache.org/jira/browse/KAFKA-12477 > > Cheers, >

[DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi everyone, I'd like to discuss the following proposal to make the CooperativeStickyAssignor as the default assignor. https://cwiki.apache.org/confluence/display/KAFKA/KIP-726%3A+Make+the+CooperativeStickyAssignor+as+the+default+assignor Any comments are welcomed. Thank you. Luke

KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi everyone, I'd like to discuss the following proposal to make the CooperativeStickyAssignor as the default assignor. https://cwiki.apache.org/confluence/display/KAFKA/KIP-726%3A+Make+the+CooperativeStickyAssignor+as+the+default+assignor Any comments are welcomed. Thank you. Luke

Re: [DISCUSS] KIP-725: Make the CooperativeStickyAssignor as the default assignor

> Sagar. > > On Fri, Mar 26, 2021 at 12:53 PM Luke Chen wrote: > > > Hi everyone, > > > > I'd like to discuss the following proposal to make the > > CooperativeStickyAssignor as the default assignor. > > > > > > > https://cwiki.apache.org/conf

[DISCUSS] KIP-725: Make the CooperativeStickyAssignor as the default assignor

Hi everyone, I'd like to discuss the following proposal to make the CooperativeStickyAssignor as the default assignor. https://cwiki.apache.org/confluence/display/KAFKA/KIP-725%3A+Make+the+CooperativeStickyAssignor+as+the+default+assignor Any comments are welcomed. Thank you. Luke

[jira] [Created] (KAFKA-12561) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic()

Luke Chen created KAFKA-12561: - Summary: Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic() Key: KAFKA-12561 URL: https://issues.apache.org/jira/browse/KAFKA-12561 Project

[jira] [Created] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

Luke Chen created KAFKA-12495: - Summary: Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor Key: KAFKA-12495 URL: https://issues.apache.org/jira/browse/KAFKA-12495

Re: [ANNOUNCE] New committer: Tom Bentley

Congratulations! Federico Valeri 於 2021年3月16日 週二 上午4:11 寫道： > Congrats, Tom! > > Well deserved. > > On Mon, Mar 15, 2021, 8:09 PM Paolo Patierno wrote: > > > Congratulations Tom! > > > > Get Outlook for Android > > > > > > From: Guozhang

[jira] [Created] (KAFKA-12464) Enhance constrained sticky Assign algorithm

Luke Chen created KAFKA-12464: - Summary: Enhance constrained sticky Assign algorithm Key: KAFKA-12464 URL: https://issues.apache.org/jira/browse/KAFKA-12464 Project: Kafka Issue Type

Re: [ANNOUNCE] New Kafka PMC Member: Chia-Ping Tsai

Congratulations Chia-Ping! 恭喜大大！！ Luke deng ziming 於 2021年3月13日 週六 上午8:52 寫道： > Congratulations Chia-Ping! > > > On Mar 13, 2021, at 05:39, Sophie Blee-Goldman > wrote: > > > > Congrats Chia-Ping! Thanks for all your contributions > > > > On Fri, Mar 12, 2021 at 12:24 PM Mickael Maison < >

<    4   5   6   7   8   9   10   >