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

t; the RangeAssignor will 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 CooperativeStickyAss

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 zook

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

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 f

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

2. Let's 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 Rya

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

n time, 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 in

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 (non-binding

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"

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: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-752%3A+Suppo

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. > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP

[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 c

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

to say > > > > > ConsumerRebalanceListener::onPartitionsLost, not > > > > Consumer::onPartitionsLost > > > > > > > > > > On Mon, Apr 12, 2021 at 8:17 AM Chris Egerton > > > > > wrote: > > > > > > > > > > > Hi Sophie

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 Israel

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 t

[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 --zook

[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

ase if 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

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: > > > >> Hello

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 < > htt

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

r the group has decided to move > > > forward 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

[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

KIP-726. Here's my > > take: > > > > 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

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

el Juma wrote: > 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,

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

work out 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-

[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

hanks! > 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.

[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-

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 W

[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 < > mic

Re: Kafka logos

The 2nd one is with a subtitle: *Distributed publish-subscribe messaging system*, which I believe is the old one. The home page log with: *A Distributed Streaming Platform *should be the newer one. Please correct me if I'm wrong. Thanks. Luke On Wed, Mar 3, 2021 at 6:42 AM Justin Mclean wrote:

[jira] [Resolved] (KAFKA-10665) Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all]

[ https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-10665. --- Resolution: Fixed > Flaky T

Re: Splitting partition may cause message loss for consumers

Hi Okada san, Yes, I agree the "latest" setting in this situation is not good, and we should document it. But I don't think we should change the default auto.offset.reset setting to the earliest. The auto.offset.reset setting starts before kafka V1.0, which means, there are already a lot of users u

Re: About Kafka 2.7.0 source code compilation error

Yes, and also, you can check the readme in kafka github repo for more details. ref: https://github.com/apache/kafka/blob/trunk/README.md Thanks. Luke On Fri, Feb 19, 2021 at 9:51 AM deng ziming wrote: > Hello, please use gradlew, for example `./gradlew jar` `./gradlew idea`, > or you can use th

[jira] [Reopened] (KAFKA-10192) Flaky test BlockingConnectorTest#testBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-10192: --- Assignee: Luke Chen (was: Chris Egerton) {code:java

Re: [DISCUSS] Apache Kafka 2.6.2 release

ttps://stackoverflow.com/a/61677956. So, you can continue to cut the rc. Thank you very much. Luke On Wed, Feb 10, 2021 at 11:19 AM Luke Chen wrote: > I just saw the defect KAFKA-12312 > <https://issues.apache.org/jira/browse/KAFKA-12312>, so I brought it to > your attention. > D

Re: [DISCUSS] Apache Kafka 2.6.2 release

I don't have a strong argument against including > it. > > However > > I aim to cut the rc tomorrow or Thursday, and if it hasn't been > > cherrypicked by then > > I won't block the release on it. > > > > On Tue, Feb 9, 2021 at 4:53 PM Luke Chen

Re: [DISCUSS] Apache Kafka 2.6.2 release

y-pick the fix into 2.6 and 2.7. What do you think? Thank you. Luke On Wed, Feb 10, 2021 at 3:24 AM Ismael Juma wrote: > Can you elaborate why this needs to be in 2.6? Seems like an improvement > versus a critical bug fix. > > Ismael > > On Mon, Feb 8, 2021 at 6:39 PM Luke

Re: [DISCUSS] Apache Kafka 2.6.2 release

Hi Sophie, I found there is 1 issue that should be cherry-picked into 2.6 and 2.7 branches: KAFKA-12312 . Simply put, *Scala* *2.13.4* is released at the end of 2020, and we upgraded to it and fixed some compatible issues on this PR

Re: [apache/kafka] KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker

Hi Committers, please help Ramens add JIRA account: *ramkrish1489* into contribution list. Thanks. Luke On Wed, Feb 3, 2021 at 2:10 PM Ramesh Krishnan wrote: > Hi Luke, > > Please find my Jira ID . > > ramkrish1489 > > Thanks > Ramens > > On Wed, 3 Feb 2021

Re: [apache/kafka] KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker

Hi Ramesh, Do you have the JIRA account? I cannot find your name. You need to have a JIRA account first, and then the committer will grant your access. Thanks. Luke On Wed, Feb 3, 2021 at 1:03 PM Ramesh Krishnan wrote: > Hi Konstantine, > > Thanks for reviewing the PR [https://github.com/apache

Re: How to build KAFKA 2.7 on z/OS platform

Hi Rabast, Gradle is just a build automation tool, and we still build the source code using javac, so your question: 1. Can I use javac and compile the source code, and pack them with jar manually --> Yes 2. which sequence is recommended? --> You might need to refer to the gradle build dependency

[jira] [Created] (KAFKA-12229) Fix flaky MirrorSourceConnectorTest.testRefreshTopicPartitionsTopicOnTargetFirst test

Luke Chen created KAFKA-12229: - Summary: Fix flaky MirrorSourceConnectorTest.testRefreshTopicPartitionsTopicOnTargetFirst test Key: KAFKA-12229 URL: https://issues.apache.org/jira/browse/KAFKA-12229

[jira] [Created] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

Luke Chen created KAFKA-12211: - Summary: NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir Key: KAFKA-12211 URL: https://issues.apache.org/jira/browse/KAFKA-12211

[jira] [Created] (KAFKA-12194) fix flaky AdjustStreamThreadCountTest tests

Luke Chen created KAFKA-12194: - Summary: fix flaky AdjustStreamThreadCountTest tests Key: KAFKA-12194 URL: https://issues.apache.org/jira/browse/KAFKA-12194 Project: Kafka Issue Type: Test

Re: How does a consumer know the given partition is removed?

ble. > > > > > > Hi Boyuan, > > > > The consumer has methods partitionsFor() and listTopics(). Probably > > there is a better way to get the information you want that I am not > > aware of. > > > > Best, > > Bruno > > > > On

Re: How does a consumer know the given partition is removed?

Hi Boyuan, You can create a *ConsumerRebalanceListener* and do something you want when *onPartitionsRevoked. * Please check this java doc for more information: https://kafka.apache.org/27/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html Thanks. Luke On Thu, Jan 7, 2021 at

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-8460: -- > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartit

Re: Why many "Load Bug xxx" JIRA bug by Tim?

ias > > > On 1/6/21 1:14 AM, M. Manna wrote: > > I had to register this as spam and block them. I couldn’t disable it from > > ASF JiRA. > > > > I’m also curious to know how/why such surge occurred. > > > > Regards, > > > > On Wed, 6 Jan

Why many "Load Bug xxx" JIRA bug by Tim?

Hi, I received a lot of JIRA notification emails today, and they are all titled: "Load Bug xxx" by Tim. The bug content doesn't look like a real bug, they are like generated by automation. I'm wondering why that could happen? Do we have any way to delete them all? Thanks. Luke

Re: kafka.apache.org/ top navigation

Hi Tyler, This is the right place to discuss it, or in JIRA. I saw there's a similar issue opened recently: KAFKA-10883 , just not in English. If you have anything updated or PR opened, please associate/update in the JIRA ticket. (And help update i

[jira] [Created] (KAFKA-10854) Fix flaky kafka.network.SocketServerTest.testConnectionRatePerIp test

Luke Chen created KAFKA-10854: - Summary: Fix flaky kafka.network.SocketServerTest.testConnectionRatePerIp test Key: KAFKA-10854 URL: https://issues.apache.org/jira/browse/KAFKA-10854 Project: Kafka

[jira] [Created] (KAFKA-10754) Fix flaky shouldShutdownSingleThreadApplication test

Luke Chen created KAFKA-10754: - Summary: Fix flaky shouldShutdownSingleThreadApplication test Key: KAFKA-10754 URL: https://issues.apache.org/jira/browse/KAFKA-10754 Project: Kafka Issue Type

Re: KAFKA-6181 : Yeva Byzek

Hi Prithvi, You need the JIRA permission to allow you to assign tickets to yourselves. I cannot help you to assign a JIRA ticket to you if I don't know your jira ID, either. Please check How to contribute page

Re: [ANNOUNCE] New committer: A. Sophie Blee-Goldman

Congratulations, Sophie! You always provide good review comments for my PRs. Well deserved! Luke On Tue, Oct 20, 2020 at 9:23 AM Rankesh Kumar wrote: > Many congratulations, Sophie. > > Best regards, > Rankesh > > > > On 20-Oct-2020, at 12:34 AM, Gwen Shapira wrote: > > > > Congratulations, So

Re: [ANNOUNCE] New committer: Chia-Ping Tsai

Congratulations! Chia-Ping大大! Well deserved! Luke On Tue, Oct 20, 2020 at 2:30 AM Mickael Maison wrote: > Congrats Chia-Ping! > > On Mon, Oct 19, 2020 at 8:29 PM Ismael Juma wrote: > > > > Congratulations Chia-Ping! > > > > Ismael > > > > On Mon, Oct 19, 2020 at 10:25 AM Guozhang Wang > wrote

[jira] [Created] (KAFKA-10482) Fix flaky testDynamicListenerConnectionCreationRateQuota

Luke Chen created KAFKA-10482: - Summary: Fix flaky testDynamicListenerConnectionCreationRateQuota Key: KAFKA-10482 URL: https://issues.apache.org/jira/browse/KAFKA-10482 Project: Kafka Issue

Re: New Website Layout

the new layout is the tags are > > > empty, > > > > and no longer enclose the config name, > > > > > > > > > > > > > > > > batch.size > > > > > > > > > > > > meaning you can

Re: New Website Layout

When entering streams doc, it'll always show: *You're viewing documentation for an older version of Kafka - check out our current documentation here.* On Wed, Aug 5, 2020 at 6:44 PM Ben Stopford wrote: > Thanks for the PR and feedback Michael. Appreciated. > > On Wed, 5 Aug 2020 at 10:49, Mick

[jira] [Reopened] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-8098: -- > Flaky Test AdminClientIntegrationTest#testConsumerGro

[jira] [Created] (KAFKA-10255) Fix flaky testOneWayReplicationWithAutorOffsetSync1 test

Luke Chen created KAFKA-10255: - Summary: Fix flaky testOneWayReplicationWithAutorOffsetSync1 test Key: KAFKA-10255 URL: https://issues.apache.org/jira/browse/KAFKA-10255 Project: Kafka Issue

Re: First time patch submitter advice

Hi Michael, The failed unit test has already handled here: https://issues.apache.org/jira/browse/KAFKA-10155 https://issues.apache.org/jira/browse/KAFKA-10147 So, maybe you can ignore the test errors and mention the issue number in PR. Thanks. Luke On Mon, Jun 15, 2020 at 3:23 PM Michael Carter

[jira] [Created] (KAFKA-10118) Improve stickiness verification for AbstractStickyAssignorTest

Luke Chen created KAFKA-10118: - Summary: Improve stickiness verification for AbstractStickyAssignorTest Key: KAFKA-10118 URL: https://issues.apache.org/jira/browse/KAFKA-10118 Project: Kafka

[jira] [Created] (KAFKA-10083) fix failed testReassignmentWithRandomSubscriptionsAndChanges

Luke Chen created KAFKA-10083: - Summary: fix failed testReassignmentWithRandomSubscriptionsAndChanges Key: KAFKA-10083 URL: https://issues.apache.org/jira/browse/KAFKA-10083 Project: Kafka

[jira] [Created] (KAFKA-10082) fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment

Luke Chen created KAFKA-10082: - Summary: fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment Key: KAFKA-10082 URL: https://issues.apache.org/jira/browse/KAFKA-10082 Project

[jira] [Created] (KAFKA-10081) Execution failed for task ':clients:spotbugsMain' in recent build

Luke Chen created KAFKA-10081: - Summary: Execution failed for task ':clients:spotbugsMain' in recent build Key: KAFKA-10081 URL: https://issues.apache.org/jira/browse/KAFKA-10081 Proj

Re: Contribute to Kafka

Hi Monish, You need to sign up a JIRA account first: https://issues.apache.org/jira/browse/KAFKA And then, reply your JIRA id in the email, to let the Kafka commiters know which JIRA ID to grant permission. Thanks. Luke On Mon, May 25, 2020 at 11:40 PM Monish wrote: > Hi, > > I would like to c

Re: Want to remove the archive

Hi Satya, I think Matthias had replied your mail on 5/11. Please check it here: https://lists.apache.org/thread.html/r6bd3cf8f092accdf59c4b5b878d62faaa1a9de074b31ecf4cb7a0b64%40%3Cdev.kafka.apache.org%3E Thanks. On Wed, May 20, 2020 at 9:08 PM Satya Kotni wrote: > Any update on this? > > Thanks

[jira] [Created] (KAFKA-10004) using kafka-configs.sh --describe for brokers will have error when querying default broker

Luke Chen created KAFKA-10004: - Summary: using kafka-configs.sh --describe for brokers will have error when querying default broker Key: KAFKA-10004 URL: https://issues.apache.org/jira/browse/KAFKA-10004

[jira] [Created] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

Luke Chen created KAFKA-9863: Summary: update the deprecated --zookeeper option in the documentation into --bootstrap-server Key: KAFKA-9863 URL: https://issues.apache.org/jira/browse/KAFKA-9863 Project

Need JIRA permission to self-assign tickets

Hi devs, I need the JIRA permission to self-assign tickets. Please help grant me the permission. JIRA username: showuon Thank you very much. Luke

Request permission to "Create KIP" for user: showuon

Hi Devs, I’d like to create a KIP and need the access to the wiki page. Please help. My wiki ID: showuon. Thank you. Luke

request to be added to the contributor list

Hi Kafka, I'd like to become contributor for Apache Kafka project. Please help add me into the contributor list. If there's anything else I need to do, please let me know. Thank you very much. Luke

<    5   6   7   8   9   10