request for permission to create KIP

[KUN DU]

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

[KUN DU]

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

[KUN DU]

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

[KUN DU]

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 (JIRA)]

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)