Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

I think this kip will implement a task in sinkTask ? right? On Sat, Nov 2, 2019 at 1:06 AM Ryanne Dolan wrote: > Hey y'all, Ning Zhang and I would like to start the vote for the following > small KIP: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-545%3A+support+automated+consumer+o

Re: question about offsetSync

his: `downstreamTargetOffset - lastSyncDownstreamOffset >= maxOffsetLag` meaning not sync offset for long time, should we rewrite ? On Sat, Nov 2, 2019 at 12:41 AM Xu Jianhai wrote: > Hi: > I am engineer from China, I review kafka mirror latest impl, but I do > not figure out the reason why Partit

question about offsetSync

Hi: I am engineer from China, I review kafka mirror latest impl, but I do not figure out the reason why PartitionState update like that: ``` // true if we should emit an offset sync boolean update(long upstreamOffset, long downstreamOffset) { boolean shouldSyncOffsets = false;

Re: contribution

-longer actively worked on tasks (you can contact the > current assignee on the ticket itself by leaving a comment to ask politely > if you can take it over). > > Guozhang > > On Tue, Oct 29, 2019 at 9:56 AM Xu Jianhai wrote: > > > More question, how can I get

Re: contribution

%20KAFKA%20AND%20labels%20%3D%20project%20AND%20status%20%3D%20Open Who is assigner? How can I contact to get the task? On Tue, Oct 29, 2019 at 10:55 PM Xu Jianhai wrote: > Hi, after read contribution page: > https://kafka.apache.org/contributing.html , I wish add my jira name: Xu > Ji

contribution

Hi, after read contribution page: https://kafka.apache.org/contributing.html , I wish add my jira name: Xu JianHai to contributor list. Have a question, just provide jira name is right?

Re: [DISCUSS] KIP-515: Reorganize checkpoint system in log cleaner to be per partition

The sentence ` (KAFKA-4545 ) ` could be change to `KAFKA-4545 < https://issues.apache.org/jira/browse/KAFKA-4545 >` ? On Sun, Oct 13, 2019 at 2:08 AM Richard Yu wrote: > Hi Jun, Jason, > > I've updated the

Re: [VOTE] KIP-511: Collect and Expose Client's Name and Version in the Brokers

+1 On Mon, Oct 14, 2019 at 3:47 PM David Jacot wrote: > Hi all, > > Jun, > The new fields are not flexible fields while the request and response are > flexible versions. It does not cost us because the version of the request > is bumped anyway to enable the flexible versions. The rationale behin

join kafka contribution

Hi: I am engineer from Bytedance, living in China. because of related job, I wish join kafka community and make some contribution. but I can not know how to kickstart. I try to resolve some ut, but I can not get response when I comment "maybe I can try it", meaning no assignee for me. so what s

join kafka

join kafka