request for permission to create KIP
Hey, I want to create a KIP for https://issues.apache.org/jira/browse/KAFKA-7711 to initiate discussion. Can someone grant me permission? Thanks, Kun
[DISCUSS] KIP-514: Add a bounded flush() API to Kafka Producer
Hi, I would like to start discussion on KIP-514 that proposes we add a bounded flush() API to producer. Link to the KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-514%3A+Add+a+bounded+flush%28%29+API+to+Kafka+Producer Suggestions and feedback are welcome! Thanks, Kun
Re: [jira] [Created] (KAFKA-9198) StopReplica handler should complete pending purgatory operations
Looks like it is the same issue as https://issues.apache.org/jira/browse/KAFKA-8571 And there is a PR for that https://github.com/apache/kafka/pull/7069 Jason Gustafson (Jira) 于2019年11月16日周六 上午9:57写道: > Jason Gustafson created KAFKA-9198: > -- > > Summary: StopReplica handler should complete pending > purgatory operations > Key: KAFKA-9198 > URL: https://issues.apache.org/jira/browse/KAFKA-9198 > Project: Kafka > Issue Type: Bug > Reporter: Jason Gustafson > Assignee: Jason Gustafson > > > When a reassignment completes, the current leader may need to be shutdown > with a StopReplica request. It may still have fetch/produce requests in > purgatory when this happens. We do not have logic currently to force > completion of these requests which means they are doomed to eventually > timeout. This is mostly an issue for produce requests which use the default > request timeout of 30s. > > > > -- > This message was sent by Atlassian Jira > (v8.3.4#803005) >
Re: [VOTE] KIP-514 Add a bounded flush() API to Kafka Producer
Rebased the PR based on latest trunk, can we merge the PR? Kun radai 于2019年12月13日周五 上午9:26写道: > i also have a PR :-) > https://github.com/apache/kafka/pull/7569 > > On Thu, Dec 12, 2019 at 9:50 PM Gwen Shapira wrote: > > > > You got 3 binding votes (Joel, Harsha, Ismael) - the vote passed on Nov > 7. > > > > Happy hacking! > > > > On Thu, Dec 12, 2019 at 11:35 AM radai > wrote: > > > > > > so can we call this passed ? > > > > > > On Thu, Nov 7, 2019 at 7:43 AM Satish Duggana < > satish.dugg...@gmail.com> wrote: > > > > > > > > +1 (non-binding) > > > > > > > > On Thu, Nov 7, 2019 at 8:58 PM Ismael Juma > wrote: > > > > > > > > > > +1 (binding) > > > > > > > > > > On Thu, Oct 24, 2019 at 9:33 PM radai > wrote: > > > > > > > > > > > Hello, > > > > > > > > > > > > I'd like to initiate a vote on KIP-514. > > > > > > > > > > > > links: > > > > > > the kip - > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-514%3A+Add+a+bounded+flush%28%29+API+to+Kafka+Producer > > > > > > the PR - https://github.com/apache/kafka/pull/7569 > > > > > > > > > > > > Thank you > > > > > > >
[jira] [Created] (KAFKA-7711) Add a bounded flush() API to Kafka Producer
kun du created KAFKA-7711: - Summary: Add a bounded flush() API to Kafka Producer Key: KAFKA-7711 URL: https://issues.apache.org/jira/browse/KAFKA-7711 Project: Kafka Issue Type: Improvement Reporter: kun du Currently the call to Producer.flush() can be hang there for indeterminate time. It is a good idea to add a bounded flush() API and timeout if producer is unable to flush all the batch records in a limited time. In this way the caller of flush() has a chance to decide what to do next instead of just wait forever. -- This message was sent by Atlassian JIRA (v7.6.3#76005)