Re: [VOTE] KIP-357: Add support to list ACLs per principal

Hi All, The vote has passed with 3 binding votes (Harsha, Dong Lin, Gwen) and 6 non-binding votes (Priyank, Ted, Jakub, Satish, Mickael, Adam). Thanks everyone for the votes. Thanks, Manikumar On Mon, Sep 17, 2018 at 2:49 AM Gwen Shapira wrote: > +1 (binding) > > On Sun, Sep 16, 2018 at

Re: Accessing Topology Builder

Hello Jorge, >From the TracingProcessor implementation it seems you want to track per-processor processing latency, is that right? If this is the case you can actually use the per-processor metrics which include latency sensors. If you do want to track, for a certain record, what's the latency

Re: [VOTE] KIP-357: Add support to list ACLs per principal

+1 (binding) On Sun, Sep 16, 2018 at 12:22 AM, Dong Lin wrote: > Thanks for the KIP Manikumar. The feature makes sense. > > +1 (binding) > > On Mon, Sep 10, 2018 at 7:07 AM, Manikumar > wrote: > > > Bump! > > > > On Tue, Sep 4, 2018 at 11:58 PM Adam Bellemare > > > wrote: > > > > > +1 (non

Re: Accessing Topology Builder

Thanks for your answer, Matthias! What I'm looking for is something similar to interceptors, but for Stream Processors. In Zipkin -and probably other tracing implementations as well- we are using Headers to propagate the context of a trace (i.e. adding metadata to the Kafka Record, so we can

Re: [VOTE] KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde

People cannot pick if their vote is binding or not. If a committer (https://kafka.apache.org/committers) votes, it's binding; otherwise, not. Thus, there is no default -- it depends who votes. -Matthias On 9/13/18 2:41 PM, Joan Goyeau wrote: > Ok so a +1 is non binding by default. > > On

Re: [DISCUSS] KIP-372: Naming Joins and Grouping

Thant for the update Bill. LGTM. On 9/14/18 5:33 PM, Guozhang Wang wrote: > Hello Bill, > > I've made another pass over the wiki page and it lgtm now. Thanks! > > > Guozhang > > > On Fri, Sep 14, 2018 at 3:05 PM, John Roesler wrote: > >> Hey Bill (and Guozhang), >> >> Apologies. I

Re: Accessing Topology Builder

>> I'm experimenting on how to add tracing to Kafka Streams. What do you mean by this exactly? Is there a JIRA? I am fine removing `final` from `InternalTopologyBuilder#addProcessor()` -- it's an internal class. However, the diff also shows > public Topology(final InternalTopologyBuilder

Re: [VOTE] KIP-361: Add Consumer Configuration to Disable Auto Topic Creation

+1 (binding) -Matthias On 9/14/18 4:57 PM, Ismael Juma wrote: > Thanks for the KIP, +1 (binding). > > Ismael > > On Fri, Sep 14, 2018 at 4:56 PM Dhruvil Shah wrote: > >> Hi all, >> >> I would like to start a vote on KIP-361. >> >> Link to the KIP: >> >>

Re: [DISCUSS] KIP-358: Migrate Streams API to Duration instead of long ms times

Dear commiters, I got two binding +1 in [VOTE] thread for this KIP [1]. I still need one more. Please, take a look at KIP. [1] https://lists.apache.org/thread.html/e976352e7e42d459091ee66ac790b6a0de7064eac0c57760d50c983b@%3Cdev.kafka.apache.org%3E В Чт, 13/09/2018 в 19:33 +0300, Nikolay

Re: [VOTE] KIP-361: Add Consumer Configuration to Disable Auto Topic Creation

Thanks, Dhruvil. +1 (non-binding). Colin On Sun, Sep 16, 2018, at 09:10, Manikumar wrote: > +1 (non-binding) > > Thanks for the KIP. > > On Sun, Sep 16, 2018 at 2:09 AM Bill Bejeck wrote: > > > Thanks for the KIP. This is a great addition. > > > > +1(non-binding) > > > > Bill > > > > On

[jira] [Resolved] (KAFKA-5789) Deleted topic is recreated when consumer subscribe the deleted one

[ https://issues.apache.org/jira/browse/KAFKA-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5789. -- Resolution: Duplicate Resolving as duplicate of KAFKA-7320/KIP-361 > Deleted topic is recreated when

Re: [VOTE] KIP-361: Add Consumer Configuration to Disable Auto Topic Creation

+1 (non-binding) Thanks for the KIP. On Sun, Sep 16, 2018 at 2:09 AM Bill Bejeck wrote: > Thanks for the KIP. This is a great addition. > > +1(non-binding) > > Bill > > On Sat, Sep 15, 2018 at 12:06 PM Gwen Shapira wrote: > > > Thank you. This has been a source of surprises and confusion for

Build failed in Jenkins: kafka-trunk-jdk8 #2969

See Changes: [lindong28] Revert 4e311 KAFKA-5690 since KIP-357 has not passed vote -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [ANNOUNCE] New Kafka PMC member: Dong Lin

Congrats Dong! On Sat, Sep 15, 2018 at 4:40 PM Bill Bejeck wrote: > Congrats! > > On Sat, Sep 15, 2018 at 1:27 PM Jorge Esteban Quilcate Otoya < > quilcate.jo...@gmail.com> wrote: > > > Congratulations!! > > > > El sáb., 15 sept. 2018 a las 15:18, Dongjin Lee () > > escribió: > > > > >

Jenkins build is back to normal : kafka-trunk-jdk8 #2968

See

Re: [VOTE] KIP-357: Add support to list ACLs per principal

Thanks for the KIP Manikumar. The feature makes sense. +1 (binding) On Mon, Sep 10, 2018 at 7:07 AM, Manikumar wrote: > Bump! > > On Tue, Sep 4, 2018 at 11:58 PM Adam Bellemare > wrote: > > > +1 (non binding) - would really like to see this one. > > > > On Mon, Sep 3, 2018 at 12:18 PM,

[jira] [Reopened] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-5690: - > kafka-acls command should be able to list per principal >

[jira] [Resolved] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5690. - Resolution: Fixed > kafka-acls command should be able to list per principal >