Re: [KAFKA-16361] Rack aware sticky assignor minQuota violations

Please check the pr , the logic in AbstractStickyAssignor has many mistakes, though it's been a long time since pr submitted, I couldn't remember the whole detail now. Julien Opoix 于2024年5月14日周二 03:55写道： > Hi there, > > We're facing a critical issue

plz help me code review

Hi kafka team: I raise a pr https://github.com/apache/kafka/pull/13965 to fix https://issues.apache.org/jira/browse/KAFKA-15106, it mentions some serious bug and no one check it for a long time, plz help me review if could. thx! these bugs are in

Re: [VOTE] KIP-944 Support async runtimes in consumer, votes needed!

Hi Erik: I read KIP-944 and email list roughly, it seems most Java developer not familiar with the conception of "coroutine" so cannot imagine why code of one function without Thread.start() may run in separate threads and even developer couldn't control it. Maybe you need a more elaborate

Re: [DISCUSS] KIP-694: Support Reducing Partitions for Topics

Does the progress of the KIP have any news? I think this feature is reasonable Guoqiang Shu 于2021年3月9日周二 22:31写道： > > Thanks Guozhang for the comments! Again sorry for the very late response. > We took time to further verify the implementation internally and rebased > the proposal on top of our

Re: Filtering support on Fetch API

server-side message filter had been talked for a very very long time, I notice serveral years ago kafka community already discuss this feature. kafka community still no plan implement it for some reason: - they dont want to break the fetch zero-copy advantage - kafka think stream project is

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

Hi Haruki Okada: i read your comment, thx for your detail explain! add backlog parameter is a useful suggestion, hope it could added to kafka. Haruki Okada 于2021年8月2日周一 上午7:43写道： > Hi, Kafka. > > I would like to start a vote on KIP that makes SocketServer acceptor's > backlog size

kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control)

Hi: I have submit a kafka jira https://issues.apache.org/jira/browse/KAFKA-9211 this describe after we upgrade kafka from 0.10.0.1 to 2.3.0 , it triggered tcp ack delay,and in wost situation, a 1KB message produce request may use 3500ms to

is reduce partition necessary

hi: so far kafka doesn't support reduce partition num for some reason, but sometimes we need to have this function to resolve some problems. 1. we have some topics with too many partitions(more than 1000) used 2 years, and lots of consumer groups subscribe them, now these topics impact

hope add permission to contribute

Hi: I want to get permission to make some contribute, plz add me if could,thx! my jira account: flashmouse my wiki account: flashmouse

Re: server-side message filter

-grained grouping of messages based on the consumer subscriptions? > > Guozhang > > On Wed, Aug 28, 2019 at 8:14 AM Adam Bellemare > wrote: > > > I do not think this will be implemented in the server. Why not simply > > create a consumer that filters as required and outputs to

server-side message filter

Hi, I want to know whether kafka has any plan to filter message on server-side.this can reduce network flow obviously when many groups subscribe the same one topic and only need part of message.