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

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

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 >

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,

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

Re: New Website Layout

yout is the tags are > > > empty, > > > > and no longer enclose the config name, > > > > > > > > > > > > > > > > batch.size > > > > > > > > > > > > meaning you can't click on th

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,

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

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

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

s > > > 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 2021 at 03

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

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

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: How does a consumer know the given partition is removed?

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

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

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

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

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

(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

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

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

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

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: [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: [DISCUSS] Apache Kafka 2.6.2 release

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 Chen wrot

Re: [DISCUSS] Apache Kafka 2.6.2 release

gument 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 wrote: > > > > > Hi Is

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.

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

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>

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

[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

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

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

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:

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

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

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

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

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...@

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

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

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

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

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

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

Re: [DISCUSS] KIP-780: Support fine-grained compression options

Hi Dongjin, Thanks for the KIP, and the benchmark results. It makes sense to me. Just one question: > compression.zstd.window: enables long mode; the log of the window size that zstd uses to memorize the compressing data. (available: [10, 22], default: 0 (disables long mode.)) It said, available

Re: Why need handle delete topic in topic change event

geHandler to only handle child add events? > > > 2021年10月12日 上午10:23，Luke Chen 写道： > > > > Hi 晓兵, > > Are you saying we should not call `removeTopic` because the topic znode > is > > deleted? > > Have a quick look at the `controllerContext#removeTopic` impl

Re: Why need handle delete topic in topic change event

Hi 晓兵, Are you saying we should not call `removeTopic` because the topic znode is deleted? Have a quick look at the `controllerContext#removeTopic` implementation, it looks like we only clean up the metrics, and local maps. Why is it a problem we called it here? Does it caused any error? Could you

Re: [DISCUSS] Apache Kafka 3.1.0 release

Hi David, KIP-766 is merged into trunk. Please help add it into the release plan. Thank you. Luke On Mon, Oct 11, 2021 at 10:50 PM David Jacot wrote: > Hi Michael, > > Sure. I have updated the release plan to include it. Thanks for the > heads up. > > Best, > David > > On Mon, Oct 11, 2021 at

[DISCUSS] KIP-782: Expandable batch size in producer

Hi Kafka dev, I'd like to start the discussion for the proposal: KIP-782: Expandable batch size in producer. The main purpose for this KIP is to have better memory usage in producer, and also save users from the dilemma while setting the batch size configuration. After this KIP, users can set a

Re: [DISCUSS] KIP-782: Expandable batch size in producer

Hi Ismael and all devs, Is there any comments/suggestions to this KIP? If no, I'm going to update the KIP based on my previous mail, and start a vote tomorrow or next week. Thank you. Luke On Mon, Oct 18, 2021 at 2:40 PM Luke Chen wrote: > Hi Ismael, > Thanks for your comments. > &g

Re: [SPAM] Re: Why does Kafka have a higher throughput than Redis?

Hi Vitor, I'm not the expert, either, but I think Andrew's answer is pretty much the reasons why Kafka is doing good. And I'm not too familiar with Redis, either. But I'd say, there are many configurations in each product to increase the throughput, and the use cases are different, the comparison

Re: Kafka client 2.7.1 missing JaasUtils.isZkSecurityEnabled() method

Hi Alexandre Yes, you're right. We renamed the `isZkSecurityEnabled` method name into `isZkSaslEnabled`, because it checked sasl config only. You can check here . If you want

Re: [VOTE] KIP-764 Configurable backlog size for creating Acceptor

Hi Okada, Thanks for the KIP. +1 (non-binding) One thing to add is that you should add ServerSocket#bind java doc link into the KIP. I don't think everyone is familiar with the definition of the method parameters. Thank you. Luke On Mon, Oct 18, 2021 at 3:43 PM Haruki Okada wrote: > Hi Kafka.

Re: [VOTE] Add TaskId field to StreamsException

Hi Sophie, Add taskId to make the exception much clear is a good improvement. + 1 (non-binding) Thank you. Luke On Mon, Oct 18, 2021 at 12:10 PM Sophie Blee-Goldman wrote: > Hey all, > > I'd like to kick off the vote on this small KIP which adds a TaskId field > to the StreamsException class.

Re: [DISCUSS] KIP-782: Expandable batch size in producer

he KIP. Why do we have to reallocate the buffer? We can keep > a > > list of buffers instead and avoid reallocation. > > > > Ismael > > > > On Sun, Oct 17, 2021, 2:02 AM Luke Chen wrote: > > > >> Hi Kafka dev, > >> I'd like to start the discussion for th

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

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

Hi everyone, I'd like to start a vote for 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

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

existing APIs, for example with poll/seek or with > listOffsets. Can you list them in the rejected alternatives section > and explain why they were rejected. > > Thanks > > > On Tue, Sep 21, 2021 at 9:47 AM Luke Chen wrote: > > > > Thanks for your feedback, Sagar,

Re: [VOTE] KIP-782: Expandable batch size in producer

iled description can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-782%3A+Expandable+batch+size+in+producer Let me know if you have other suggestions. Thank you. Luke On Sat, Oct 23, 2021 at 10:50 AM Luke Chen wrote: > Hi Artem, > Thanks for the suggestion. Let m

[VOTE] KIP-782: Expandable batch size in producer

Hi Kafka dev, I'd like to start a vote for the proposal: KIP-782: Expandable batch size in producer. The main purpose for this KIP is to have better memory usage in producer, and also save users from the dilemma while setting the batch size configuration. After this KIP, users can set a higher

Re: [VOTE] KIP-792: Add "generation" field into consumer protocol

ank you. Luke On Fri, Dec 3, 2021 at 6:30 AM Colin McCabe wrote: > How are we going to avoid the situation where the broker restarts, and the > same generation number is reused? > > best, > Colin > > On Tue, Nov 30, 2021, at 16:36, Luke Chen wrote: > > Hi all, > > &

Re: [VOTE] KIP-799: Align behaviour for producer callbacks with documented behaviour

he KIP itself what placeholder value would be > returned. > > Regards, > Séamus. > > On Tue, 30 Nov 2021 at 09:52, Luke Chen wrote: > > > Hi Séamus, > > Thanks for the KIP! > > We definitely want to keep the producer callback consistent for all

Re: [ANNOUNCE] New Kafka PMC member: David Jacot

Congrats, David! Well deserved. Luke deng ziming 於 2021年12月18日 週六 上午7:47 寫道： > Congrats David! > > -- > Ziming Deng > > > On Dec 18, 2021, at 7:08 AM, Gwen Shapira wrote: > > > > Hi everyone, > > > > David Jacot has been an Apache Kafka committer since Oct 2020 and has > been contributing to

  1   2   3   4   5   6   7   8   9   >