Re: [ANNOUNCE] New committer: Matthias J. Sax

2018-01-15 Thread Sriram Subramanian
Congratulations Matthias ! Well deserved! On Mon, Jan 15, 2018 at 10:22 PM, Becket Qin wrote: > Congrats, Matthias! > > On Mon, Jan 15, 2018 at 9:54 PM, Konstantine Karantasis < > konstant...@confluent.io> wrote: > > > Matthias! Congratulations! > > > > Konstantine > > > > On Mon, Jan 15, 2018 a

Re: [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram

2018-01-17 Thread Sriram Subramanian
Congratulations Rajini! On Wed, Jan 17, 2018 at 11:40 AM, Edoardo Comar wrote: > Congratulations Rajini! Bravissima! > -- > > Edoardo Comar > > IBM Message Hub > > IBM UK Ltd, Hursley Park, SO21 2JN > > > > From: Guozhang Wang > To: dev@kafk

Re: [VOTE] Allowing write access to GitHub repositories (aka GitBox)

2017-12-12 Thread Sriram Subramanian
+1 On Tue, Dec 12, 2017 at 8:22 AM, Manikumar wrote: > +1 > > On Tue, Dec 12, 2017 at 9:49 PM, Rajini Sivaram > wrote: > > > +1 > > > > Thanks, Ismael! > > > > On Tue, Dec 12, 2017 at 4:18 PM, Damian Guy > wrote: > > > > > +1 > > > > > > On Tue, 12 Dec 2017 at 15:47 Ismael Juma wrote: > > > >

Re: [Vote] KIP-150 - Kafka-Streams Cogroup

2017-06-09 Thread Sriram Subramanian
+1 On Fri, Jun 9, 2017 at 2:24 PM, Jay Kreps wrote: > +1 > > -Jay > > On Thu, Jun 8, 2017 at 11:16 AM, Guozhang Wang wrote: > > > I think we can continue on this voting thread. > > > > Currently we have one binding vote and 2 non-binging votes. I would like > to > > call out for other people es

Re: [VOTE] KIP-161: streams deserialization exception handlers

2017-06-28 Thread Sriram Subramanian
+1 On Sat, Jun 24, 2017 at 1:38 AM, Matthias J. Sax wrote: > +1 > > On 6/23/17 9:45 AM, Guozhang Wang wrote: > > +1. > > > > On Fri, Jun 23, 2017 at 6:42 AM, Bill Bejeck wrote: > > > >> Thanks for the KIP! > >> > >> +1 > >> > >> -Bill > >> > >> On Fri, Jun 23, 2017 at 7:15 AM, Damian Guy > wro

Re: [VOTE] KIP 130: Expose states of active tasks to KafkaStreams public API

2017-06-30 Thread Sriram Subramanian
+1 On Fri, Jun 30, 2017 at 12:10 AM, Damian Guy wrote: > I know i voted before, but now my vote is binding so... > > +1 (binding) > > On Thu, 18 May 2017 at 23:46 Matthias J. Sax > wrote: > > > +1 > > > > On 5/18/17 8:26 AM, Bill Bejeck wrote: > > > +1 > > > > > > On Thu, May 18, 2017 at 6:54 A

Re: [ANNOUNCE] New Kafka PMC member Ismael Juma

2017-07-05 Thread Sriram Subramanian
Congratulations Ismael! On Wed, Jul 5, 2017 at 2:06 PM, Rajini Sivaram wrote: > Congratulations, Ismael! > > On Wed, Jul 5, 2017 at 9:55 PM, Jun Rao wrote: > > > Hi, Everyone, > > > > Ismael Juma has been active in the Kafka community since he became > > a Kafka committer about a year ago. I am

Re: [ANNOUNCE] New Kafka PMC member Jason Gustafson

2017-07-12 Thread Sriram Subramanian
Congratulations Jason! On Wed, Jul 12, 2017 at 8:02 AM, Rajini Sivaram wrote: > Congratulations, Jason! > > On Wed, Jul 12, 2017 at 3:53 PM, Ismael Juma wrote: > > > Congratulations Jason! > > > > Ismael > > > > On Tue, Jul 11, 2017 at 10:32 PM, Guozhang Wang > > wrote: > > > > > Hi Everyone,

Re: [VOTE] KIP-167: Add interface for the state store restoration process

2017-07-15 Thread Sriram Subramanian
+1 On Sat, Jul 15, 2017 at 9:45 AM, Damian Guy wrote: > +1 > > On Thu, 13 Jul 2017 at 07:13 Eno Thereska wrote: > > > +1 (non-binding). > > > > Thanks Bill. > > > > Eno > > > On 12 Jul 2017, at 09:12, Bill Bejeck wrote: > > > > > > All, > > > > > > Now that we've concluded a second round of di

Re: [DISCUSS] 2017 October release planning and release version

2017-07-21 Thread Sriram Subramanian
+1! On Fri, Jul 21, 2017 at 12:35 PM, Jay Kreps wrote: > 1.0! Let's do it! > > -Jay > > On Tue, Jul 18, 2017 at 3:36 PM, Guozhang Wang wrote: > > > Hi all, > > > > With 0.11.0.0 out of the way, I would like to volunteer to be the > > release manager > > for our next time-based feature release.

Re: [VOTE] KIP-167 (Addendum): Add interface for the state store restoration process

2017-07-25 Thread Sriram Subramanian
+1 On Fri, Jul 21, 2017 at 12:08 PM, Guozhang Wang wrote: > +1 > > On Thu, Jul 20, 2017 at 11:00 PM, Matthias J. Sax > wrote: > > > +1 > > > > On 7/20/17 4:22 AM, Bill Bejeck wrote: > > > Hi, > > > > > > After working on the PR for this KIP I discovered that we need to add > and > > > additiona

Re: [VOTE] KIP-182 - Reduce Streams DSL overloads and allow easier use of custom storage engines

2017-08-24 Thread Sriram Subramanian
+1 On Thu, Aug 24, 2017 at 10:20 AM, Guozhang Wang wrote: > +1. Thanks Damian! > > On Thu, Aug 24, 2017 at 9:47 AM, Bill Bejeck wrote: > > > Thanks for the KIP! > > > > +1 > > > > Thanks, > > Bill > > > > On Thu, Aug 24, 2017 at 12:25 PM, Damian Guy > wrote: > > > > > Hi, > > > > > > I'd like

Re: [VOTE] KIP-182 - Reduce Streams DSL overloads and allow easier use of custom storage engines

2017-09-05 Thread Sriram Subramanian
mian Guy wrote: > > >>>> Hi, > > >>>> > > >>>> I've just realised we need to add two methods to StateStoreBuilder > or > > >> it > > >>>> isn't going to work: > > >>>> > > >>>>

Re: [VOTE] KIP-197: Include Connector type in Connector REST API

2017-09-08 Thread Sriram Subramanian
+1 On Fri, Sep 8, 2017 at 4:33 PM, Randall Hauch wrote: > +1 (non-binding) > > Randall > > On Fri, Sep 8, 2017 at 6:32 PM, Ted Yu wrote: > > > Hi, > > Please take a look at the following and cast your vote: > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 197+Connect+REST+API+

Re: [VOTE] KIP-198: Remove ZK dependency from Streams Reset Tool

2017-09-08 Thread Sriram Subramanian
+1 On Fri, Sep 8, 2017 at 3:04 PM, Guozhang Wang wrote: > +1, thanks. > > On Fri, Sep 8, 2017 at 1:54 PM, Bill Bejeck wrote: > > > +1 > > > > Thanks, > > Bill > > > > On Fri, Sep 8, 2017 at 4:51 PM, Matthias J. Sax > > wrote: > > > > > We want to deprecate it for 1.0.0 release. Unclear how lon

Re: [VOTE] KIP-199: Add Kafka Connect Offset Tool

2017-09-11 Thread Sriram Subramanian
+1 On Mon, Sep 11, 2017 at 2:56 PM, Gwen Shapira wrote: > +1 > > On Mon, Sep 11, 2017 at 1:33 PM Ted Yu wrote: > > > +1 > > > > On Mon, Sep 11, 2017 at 7:43 AM, Randall Hauch wrote: > > > > > I'd like to start the vote on KIP-199 to add a command line tool that > > will > > > allow Connect ope

Re: [VOTE] KIP-196: Add metrics to Kafka Connect framework

2017-09-11 Thread Sriram Subramanian
+1 On Mon, Sep 11, 2017 at 2:56 PM, Gwen Shapira wrote: > +1 > > Thanks for this. Can't wait for more complete monitoring for Connect. > > On Mon, Sep 11, 2017 at 7:40 AM Randall Hauch wrote: > > > I'd like to start the vote on KIP-196 to add metrics to the Kafka Connect > > framework so the wo

Re: [VOTE] KIP-196: Add metrics to Kafka Connect framework

2017-09-12 Thread Sriram Subramanian
gt; > > > On Mon, Sep 11, 2017 at 8:40 PM, Sriram Subramanian > > wrote: > > > > > +1 > > > > > > On Mon, Sep 11, 2017 at 2:56 PM, Gwen Shapira > wrote: > > > > > > > +1 > > > > > > > > Thanks for this.

Re: [DISCUSS] KIP-196: Add metrics to Kafka Connect framework

2017-09-12 Thread Sriram Subramanian
FWIW, I agree that time metrics have been very useful in the past. The reasoning around perf overhead seems reasonable as well. Can we agree on a subset of time metrics that we feel would be super useful for debugging? On Tue, Sep 12, 2017 at 6:08 PM, Roger Hoover wrote: > Thanks, Ewen. > > I ag

Re: [ANNOUCE] Apache Kafka 0.11.0.1 Released

2017-09-13 Thread Sriram Subramanian
Thanks for driving the release Damian. > On Sep 13, 2017, at 1:18 PM, Guozhang Wang wrote: > > Thanks for driving this Damian! > > > Guozhang > >> On Wed, Sep 13, 2017 at 4:36 AM, Damian Guy wrote: >> >> The Apache Kafka community is pleased to announce the release for Apache >> Kafka 0.11.

subscription request

2016-05-24 Thread Sriram Subramanian

subscription request

2016-05-25 Thread Sriram Subramanian

Re: subscription request

2016-05-25 Thread Sriram Subramanian
Sorry, wrong thread. On Wed, May 25, 2016 at 5:12 PM, Sriram Subramanian wrote: > >

Re: [HEADS-UP] Modification to KIP Template

2016-05-26 Thread Sriram Subramanian
++1 Sent from my iPhone > On May 26, 2016, at 7:24 PM, Gwen Shapira wrote: > > Hi Kafka Developers, > > Just a quick heads-up that I added a new section to the KIP template: "Test > Plans". > I think its a good habit to think about how a feature will be tested while > planning it. I'm talking

Re: [VOTE] KIP-65 Expose timestamps to Connect

2016-06-24 Thread Sriram Subramanian
+1 On Fri, Jun 24, 2016 at 3:03 PM, Jason Gustafson wrote: > +1 (non-binding) > > On Fri, Jun 24, 2016 at 11:26 AM, Jay Kreps wrote: > > > +1 > > > > On Fri, Jun 24, 2016 at 10:59 AM, Shikhar Bhushan > > wrote: > > > > > Since there isn't much to discuss with this KIP, bringing it to a vote >

Re: [VOTE] KIP-67: Queryable state for Kafka Streams

2016-07-07 Thread Sriram Subramanian
+1 On Thu, Jul 7, 2016 at 9:53 AM, Henry Cai wrote: > +1 > > On Thu, Jul 7, 2016 at 6:48 AM, Michael Noll wrote: > > > +1 (non-binding) > > > > On Thu, Jul 7, 2016 at 10:24 AM, Damian Guy > wrote: > > > > > Thanks Henry - we've updated the KIP with an example and the new config > > > parameter

Re: [VOTE] KIP-67: Queryable state for Kafka Streams

2016-07-12 Thread Sriram Subramanian
and v2 alive at the same time > > >> > > > > >> > > That's right. But the current live instance will be able to tell > > >> other > > >> > > instances, via its endpoint setting, whether it wants to be > > contacted > >

Re: [VOTE] KIP-67: Queryable state for Kafka Streams

2016-07-15 Thread Sriram Subramanian
So, it looks like QueryableStoreTypes would be part of the streams library, right? If a developer needs to support a new store, would they need to change code in streams? On Fri, Jul 15, 2016 at 3:15 PM, Jay Kreps wrote: > Cool, I'm +1 after the updates. > > -Jay > > On Fri, Jul 15, 2016 at 1:50

Re: [DISCUSS] KIP 20 Enable log preallocate to improve consume performance under windows and some old Linux file system

2015-04-21 Thread Sriram Subramanian
Could you describe how recovery works in this mode? Say, we had a 250 MB preallocated segment and we wrote till 50MB and crashed. Till what point do we recover? Also, on startup, how is the append end pointer set even on a clean shutdown? How does the FileChannel end position get set to 50 MB inste

Re: [DISCUSS] KIP 20 Enable log preallocate to improve consume performance under windows and some old Linux file system

2015-04-23 Thread Sriram Subramanian
:12 AM >> >> To: dev@kafka.apache.org >> >> Subject: RE: [DISCUSS] KIP 20 Enable log preallocate to improve >>consume >> >>performance under windows and some old Linux file system >> >> >> >> Hi Sriram, >> >> One sentenc

Re: [VOTE] KIP-89: Allow sink connectors to decouple flush and offset commit

2016-11-12 Thread Sriram Subramanian
+1 (binding) On Fri, Nov 11, 2016 at 9:44 PM, Ewen Cheslack-Postava wrote: > +1 (binding) > > -Ewen > > On Wed, Nov 9, 2016 at 2:16 PM, Shikhar Bhushan > wrote: > > > Hi, > > > > I would like to initiate a vote on KIP-89 > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 89%3A+A

Re: [VOTE] KIP-93: Improve invalid timestamp handling in Kafka Streams

2016-11-30 Thread Sriram Subramanian
+1 (binding) I second Ewen's point about compatibility. On Wed, Nov 30, 2016 at 2:53 AM, Damian Guy wrote: > +1 > > On Wed, 30 Nov 2016 at 05:58 Ewen Cheslack-Postava > wrote: > > > +1 (binding). > > > > Also, see my notes in discussion thread around future compatibility > > discussions for br

Re: [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams

2016-11-30 Thread Sriram Subramanian
I agree that the metadata topic is required to build a batching semantic that is intuitive. One question on the config - autostop.at I see one value for it - eol. What other values can be used? Instead, why would we not have batch.mode=true/false? On Wed, Nov 30, 2016 at 1:51 PM, Matthias J. Sa

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

2016-12-06 Thread Sriram Subramanian
@Jay 1. I totally agree on the naming. The appid for transactions is really an instance id. Any recommendation for a name is appreciated. We had thought of instance id, session id or app id and went with app id. 2. We also discussed about init() method but that could add its own set of confusion t

Re: [VOTE] KIP-94: Session Windows

2016-12-06 Thread Sriram Subramanian
+1 (binding) On Tue, Dec 6, 2016 at 3:43 PM, Ewen Cheslack-Postava wrote: > +1 binding > > -Ewen > > On Tue, Dec 6, 2016 at 3:21 PM, Bill Bejeck wrote: > > > +1 > > > > On Tue, Dec 6, 2016 at 4:55 PM, Guozhang Wang > wrote: > > > > > +1 (binding) > > > > > > On Tue, Dec 6, 2016 at 9:07 AM, Mat

Re: [VOTE]: KIP-97: The client compatibility KIP

2016-12-08 Thread Sriram Subramanian
+1 (binding) On Thu, Dec 8, 2016 at 5:42 AM, Ismael Juma wrote: > Thanks for the KIP Colin, +1 (binding) from me. > > I agree with Rajini's suggestions. Also, since the command is a public > interface, it would be good to include details in the KIP. > > Ismael > > On Wed, Dec 7, 2016 at 5:17 PM,

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

2016-12-13 Thread Sriram Subramanian
I am not sure if it is a good idea to support both init() and lazy initialization. The ideal state would have been to implement init as a non blocking api and have the rest of the methods throw uninitialized exception if init was not called. This would ensure that init can still be used by other no

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

2016-12-19 Thread Sriram Subramanian
Radai, I think it is important to understand the key requirements that we don’t want to compromise. We can then understand the tradeoffs of the different approaches. We did in fact start with the double journal approach couple of years back. I will highlight the must have requirements first and th

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

2016-12-19 Thread Sriram Subramanian
small correction in my third point - 3. IO and memory constraints - We would want a solution that *does not take* 2x the number of writes. On Mon, Dec 19, 2016 at 12:37 PM, Sriram Subramanian wrote: > Radai, > > I think it is important to understand the key requirements that we don’t

Re: [VOTE] KIP-90 Remove zkClient dependency from Streams

2016-12-20 Thread Sriram Subramanian
+1 On Tue, Dec 20, 2016 at 1:13 PM, Guozhang Wang wrote: > +1. Thanks! > > On Tue, Dec 20, 2016 at 1:01 PM, Hojjat Jafarpour > wrote: > > > Hi all, > > > > Seems that there is no opposition to this KIP. This email is to start the > > voting for this KIP. > > Once again the KIP is for removing z

Re: [DISCUSS] KIP-106 - Change Default unclean.leader.election.enabled from True to False

2017-01-03 Thread Sriram Subramanian
+1 On Tue, Jan 3, 2017 at 11:56 AM, Ian Wrigley wrote: > +1 from me too. When I talk to people in training classes, who are > typically much newer to Kafka, they tend to be surprised (and > scared/horrified) that the default is true. Much safer to set it to false > and let people change it when

Re: [VOTE] KIP-99: Add Global Tables to Kafka Streams

2017-01-03 Thread Sriram Subramanian
+1 On Tue, Jan 3, 2017 at 11:43 AM, Neha Narkhede wrote: > +1 (binding) > > On Tue, Jan 3, 2017 at 11:40 AM Ewen Cheslack-Postava > wrote: > > > +1 > > > > -Ewen > > > > On Tue, Jan 3, 2017 at 11:16 AM, Gwen Shapira wrote: > > > > > +1 > > > > > > I'm glad this super-common use-case will becom

Re: [VOTE] KIP-98: Exactly Once Delivery and Transactional Messaging

2017-02-24 Thread Sriram Subramanian
+1. Great work in driving this to a consensus. Lots of good constructive conversations. On Fri, Feb 24, 2017 at 11:48 AM, Jason Gustafson wrote: > +1 from me (duh). Thanks to all the reviewers. The KIP has been much > improved because of it! > > -Jason > > On Wed, Feb 22, 2017 at 8:48 AM, Ismael

Re: [DISCUSS] 0.10.3.0/0.11.0.0 release planning

2017-03-01 Thread Sriram Subramanian
+1 Thanks Ismael for volunteering to run the next time based release. On Wed, Mar 1, 2017 at 4:51 PM, Ismael Juma wrote: > Thanks everyone for the feedback. Since everyone was in favour and we had > covered this particular case in the time-based release plan[1], I went > ahead and updated the w

Re: [VOTE] KIP-128: Add ByteArrayConverter for Kafka Connect

2017-03-07 Thread Sriram Subramanian
+1. Looks good On Tue, Mar 7, 2017 at 10:33 PM, Ewen Cheslack-Postava wrote: > Hah, I forgot to do it in the original email, but I suppose I should make > it explicit: +1 (binding) > > -Ewen > > On Mon, Mar 6, 2017 at 9:26 PM, Gwen Shapira wrote: > > > +1 (binding) > > > > On Mon, Mar 6, 2017 a

Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API

2017-03-13 Thread Sriram Subramanian
StreamsBuilder would be my vote. > On Mar 13, 2017, at 9:42 PM, Jay Kreps wrote: > > Hey Matthias, > > Make sense, I'm more advocating for removing the word topology than any > particular new replacement. > > -Jay > > On Mon, Mar 13, 2017 at 12:30 PM, Matthias J. Sax > wrote: > >> Jay, >>

Re: [VOTE] KIP-117: Add a public AdminClient API for Kafka admin operations

2017-03-14 Thread Sriram Subramanian
+1 (binding) Nice work in driving this. On Mon, Mar 13, 2017 at 10:31 PM, Gwen Shapira wrote: > +1 (binding) > > I expressed few concerns in the discussion thread, but in general this is > super important to get done. > > On Fri, Mar 10, 2017 at 10:38 AM, Colin McCabe wrote: > > > Hi all, > >

Re: [DISCUSS] KIP-129: Kafka Streams Exactly-Once Semantics

2017-03-21 Thread Sriram Subramanian
To add to this discussion, I do think we should think about this in increments. We do a full recovery today and the EOS proposal will not make this any worse. Using store snapshot is a good option to avoid store recovery in the future but as Eno points out, all pluggable stores would need to have t

Re: [DISCUSS] KIP-129: Kafka Streams Exactly-Once Semantics

2017-03-22 Thread Sriram Subramanian
ight pay it for a transaction failure. Will transaction failures > be > > more or less common than the previous types of failures? > > Damian voiced similar concerns at the very beginning of this discussion, > not sure what his current opinion is here. > > -Michael > &

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

2017-03-29 Thread Sriram Subramanian
+1 On Wed, Mar 29, 2017 at 9:36 AM, Bill Bejeck wrote: > +1 (non-binding) > > Thanks Matthias, > Bill > > On Wed, Mar 29, 2017 at 12:18 PM, Apurva Mehta > wrote: > > > +1 (non-binding) > > > > On Wed, Mar 29, 2017 at 9:17 AM, Jay Kreps wrote: > > > > > +1 > > > > > > -Jay > > > > > > On Mon, M

Re: [VOTE] KIP-120: Cleanup Kafka Streams builder API

2017-04-05 Thread Sriram Subramanian
+1 On Tue, Apr 4, 2017 at 9:01 PM, Ewen Cheslack-Postava wrote: > +1 (binding) > > -Ewen > > On Thu, Mar 30, 2017 at 4:03 PM, Guozhang Wang wrote: > > > +1. > > > > > > On Thu, Mar 30, 2017 at 1:18 AM, Damian Guy > wrote: > > > > > Thanks Matthias. > > > > > > +1 > > > > > > On Thu, 23 Mar 201

Re: [VOTE] KIP-114: KTable state stores and improved semantics

2017-04-21 Thread Sriram Subramanian
+1 On Fri, Apr 21, 2017 at 11:06 AM, Guozhang Wang wrote: > +1 > > On Fri, Apr 21, 2017 at 10:52 AM, Bill Bejeck wrote: > > > +1 > > On Fri, Apr 21, 2017 at 1:48 PM Matthias J. Sax > > wrote: > > > > > +1 > > > > > > On 4/21/17 10:39 AM, Eno Thereska wrote: > > > > Hi there, > > > > > > > > Un

Re: What to do when file.rename fails?

2015-01-24 Thread Sriram Subramanian
The failure really means that the filesystem is configured incorrectly (from the link). In such circumstances it is best to fail and let the operations/admins know instead of working around it. On 1/24/15 9:42 AM, "Jay Kreps" wrote: >Hey guys, > >Jaikiran posted a patch on KAFKA-1853 to improve

Re: [VOTE] KIP-8: Add a flush() method to the new producer

2015-02-19 Thread Sriram Subramanian
+1 On 2/19/15 12:08 PM, "Neha Narkhede" wrote: >+1 (binding) > >On Thu, Feb 19, 2015 at 6:29 AM, Joel Koshy wrote: > >> +1 (binding) >> >> On Wed, Feb 18, 2015 at 07:03:26PM -0500, Joe Stein wrote: >> > +1 binding >> > >> > ~ Joestein >> > On Feb 18, 2015 6:50 PM, "Jay Kreps" wrote: >> > >> >

Re: Announcing the Confluent Platform built on Apache Kafka

2015-02-25 Thread Sriram Subramanian
Congratulations! On 2/25/15 11:15 AM, "Joe Stein" wrote: >Awesome! > >The future of schema management, has arrived > >~ Joestein > >On Wed, Feb 25, 2015 at 1:34 PM, Gwen Shapira >wrote: > >> Congrats, Confluent team. >> >> This is super exciting :) >> >> >> On Wed, Feb 25, 2015 at 10:31 AM

Re: [VOTE] KIP-66: Single Message Transforms for Kafka Connect

2017-01-04 Thread Sriram Subramanian
+1 On Wed, Jan 4, 2017 at 1:29 PM, Gwen Shapira wrote: > I would have preferred not to bundle transformations, but since SMT > capability is a much needed feature, I'll take it in its current form. > > +1 > > On Wed, Jan 4, 2017 at 10:47 AM, Shikhar Bhushan > wrote: > > Hi all, > > > > I'd like

Re: [VOTE] KIP-102 - Add close with timeout for consumers

2017-01-05 Thread Sriram Subramanian
+1 On Thu, Jan 5, 2017 at 6:30 PM, Ewen Cheslack-Postava wrote: > +1 > > -Ewen > > On Thu, Jan 5, 2017 at 5:48 PM, Neha Narkhede wrote: > > > +1 (binding) > > > > On Thu, Jan 5, 2017 at 2:07 PM Rajini Sivaram > > wrote: > > > > > Hi all, > > > > > > > > > I would like to start the voting proce

Re: [VOTE] KIP-105: Addition of Record Level for Sensors

2017-01-06 Thread Sriram Subramanian
+1 On Fri, Jan 6, 2017 at 8:40 AM, Bill Bejeck wrote: > +1 > > On Fri, Jan 6, 2017 at 11:06 AM, Guozhang Wang wrote: > > > +1 > > > > On Fri, Jan 6, 2017 at 2:55 AM, Damian Guy wrote: > > > > > +1 > > > > > > On Fri, 6 Jan 2017 at 10:48 Ismael Juma wrote: > > > > > > > Thanks for the KIP, +1

Re: [VOTE] KIP-103: Separation of Internal and External traffic

2017-01-06 Thread Sriram Subramanian
+1 On Fri, Jan 6, 2017 at 3:21 AM, Rajini Sivaram wrote: > Ismael, > > Thank you for the KIP. It is a very useful feature. > > +1 (non-binding) > > Regards, > > Rajini > > On Fri, Jan 6, 2017 at 10:51 AM, Ismael Juma wrote: > > > Hi all, > > > > As the discussion seems to have settled down, I w

Re: [VOTE] KIP-104: Granular Sensors for Streams

2017-01-06 Thread Sriram Subramanian
+1 On Fri, Jan 6, 2017 at 9:12 AM, Matthias J. Sax wrote: > +1 > > On 1/6/17 8:01 AM, Guozhang Wang wrote: > > +1 > > > > On Fri, Jan 6, 2017 at 5:05 AM, Bill Bejeck wrote: > > > >> +1 > >> > >> On Fri, Jan 6, 2017 at 5:57 AM, Damian Guy > wrote: > >> > >>> +1 > >>> > >>> On Fri, 6 Jan 2017 at

Re: [VOTE] KIP-104: Granular Sensors for Streams

2017-01-06 Thread Sriram Subramanian
ously voted? > > Thank you > no > > > On 6 Jan 2017, at 17:31, Sriram Subramanian wrote: > > > > +1 > > > > On Fri, Jan 6, 2017 at 9:12 AM, Matthias J. Sax > > wrote: > > > >> +1 > >> > >> On 1/6/17 8:01 AM, Guozhang Wa

Re: [VOTE] KIP-108: Create Topic Policy

2017-01-09 Thread Sriram Subramanian
+1 On Mon, Jan 9, 2017 at 3:29 PM, Apurva Mehta wrote: > (hit send too soon) > > +1 (non-binding).. that is a very well written KIP! > > On Mon, Jan 9, 2017 at 3:28 PM, Apurva Mehta wrote: > > > +1, that1 > > > > On Mon, Jan 9, 2017 at 2:47 PM, Neha Narkhede wrote: > > > >> +1 - thanks Ismael!

Re: [ANNOUNCE] New committer: Grant Henke

2017-01-11 Thread Sriram Subramanian
Congratulations Grant! On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88 patches, 90 code reviews, countless great > comments on discussio

Re: [DISCUSS] KIP-117: Add a public AdministrativeClient API for Kafka admin operations

2017-02-07 Thread Sriram Subramanian
+1 > On Feb 7, 2017, at 9:17 AM, radai wrote: > > +1. > > under ismael's "facet" approach we could always start with > AdminClient.topics() and then pile on more of them later. > >> On Tue, Feb 7, 2017 at 8:57 AM, Grant Henke wrote: >> >> +1 I think its important to focus this KIP discussio

Re: [VOTE] 0.10.2.0 RC2

2017-02-16 Thread Sriram Subramanian
+1 Verified signatures, tests and docs On Thu, Feb 16, 2017 at 9:44 AM, Neha Narkhede wrote: > +1 (binding) > > Verified signatures, quickstart, docs. > > Thanks for running the release, Ewen! > > On Thu, Feb 16, 2017 at 9:42 AM Gwen Shapira wrote: > > > +1 (binding). > > > > Verified signature

Re: [ANNOUNCE] Apache Kafka 0.10.2.0 Released

2017-02-22 Thread Sriram Subramanian
Thanks Ewen for driving this. On Wed, Feb 22, 2017 at 12:40 AM, Guozhang Wang wrote: > Thanks Ewen for driving the release! > > Guozhang > > On Wed, Feb 22, 2017 at 12:33 AM, Ewen Cheslack-Postava > > wrote: > > > The Apache Kafka community is pleased to announce the release for Apache > > Kafk

Re: [ANNOUNCE] New committer: Ismael Juma

2016-04-26 Thread Sriram Subramanian
Congratulations! On Tue, Apr 26, 2016 at 6:57 AM, Gwen Shapira wrote: > Congratulations, very well deserved. > On Apr 25, 2016 10:53 PM, "Neha Narkhede" wrote: > > > The PMC for Apache Kafka has invited Ismael Juma to join as a committer > and > > we are pleased to announce that he has accepted

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

2015-12-08 Thread Sriram Subramanian
Congrats! On Tue, Dec 8, 2015 at 2:45 PM, Jay Kreps wrote: > Congrats Ewen! > > -Jay > > On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > > > Ewen

Re: [VOTE] KIP 20 Enable log preallocate to improve consume performance under windows and some old Linux file system

2015-06-10 Thread Sriram Subramanian
+1 > On Jun 10, 2015, at 9:38 AM, Jay Kreps wrote: > > +1 > > On Tue, Jun 9, 2015 at 11:24 PM, Honghai Chen > wrote: > >> Hi Kafka, >> >>After a long discussion, please help vote again for the >> KIP. Thanks. >> >> >> >> I wrote a KIP for this after some discussion on KAF

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

2015-06-23 Thread Sriram Subramanian
I am still not convinced why a stream processing framework closely tied to Kafka will not help with this (since we are also referring to some basic transformations). The devil is in the details of the design and I would be able to better comment on it after that. I would love to see a detailed desi

Re: [ANNOUNCE] New Committer

2015-07-07 Thread Sriram Subramanian
Congrats Gwen! > On Jul 6, 2015, at 6:08 PM, Joe Stein wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to invite Gwen > Shapira as a committer and Gwen has accepted. > > Please join me on welcoming and congratulating Gwen. > > Thanks for the contribution both in the pr

Re: [VOTE] KIP-26 Add Copycat connector framework for data import/export

2015-07-14 Thread Sriram Subramanian
+1. This was long due! On 7/14/15, 4:42 PM, "Guozhang Wang" wrote: >+1. Thanks Ewen!! > >On Tue, Jul 14, 2015 at 3:01 PM, Neha Narkhede wrote: > >> +1 (binding) >> >> Thanks Ewen for taking on something that the Kafka project has long >>waited >> for! >> >> On Tue, Jul 14, 2015 at 2:58 PM, Jay

Re: Kafka Indentation

2015-07-24 Thread Sriram Subramanian
+1 for consistency. On Fri, Jul 24, 2015 at 8:51 AM, Neha Narkhede wrote: > Personally, I prefer the consistency and 2 spaces for indentation. Although > I'm in agreement with Jay about the ambition to eventually move the server > code to Java, I'd hate to make that a blocker for discussing a si

Re: [DISCUSS] KIP-28 - Add a transform client for data processing

2015-07-29 Thread Sriram Subramanian
I think Kafka and streaming are synonymous. Kafka streams or Kafka streaming really does not indicate "stream processing". On Wed, Jul 29, 2015 at 6:20 PM, Neha Narkhede wrote: > Prefer something that evokes "stream processing on top of Kafka". And since > I've heard many people conflate "stream

Re: [DISCUSS] KIP-28 - Add a transform client for data processing

2015-07-30 Thread Sriram Subramanian
I had the same thought. Kafka processor, KProcessor or even Kafka stream processor is more relevant. > On Jul 30, 2015, at 2:09 PM, Martin Kleppmann wrote: > > I'm with Sriram -- Kafka is all about streams already (or topics, to be > precise, but we're calling it "stream processing" not "topic

Re: [DISCUSS] KIP-75 - Add per-connector Converters

2016-08-12 Thread Sriram Subramanian
+1 On Fri, Aug 12, 2016 at 7:36 PM, Gwen Shapira wrote: > Looks good to me too - simple, usable and the use-case is clear. > > Gwen > > On Fri, Aug 12, 2016 at 12:56 PM, Ewen Cheslack-Postava > wrote: > > Hi all, > > > > I've added KIP-75 - Add per-connector Converters > > > > https://cwiki.apa

Re: [VOTE] KIP:71 Enable log compaction and deletion to co-exist

2016-08-15 Thread Sriram Subramanian
+1 (binding) On Mon, Aug 15, 2016 at 10:27 AM, Ismael Juma wrote: > Thanks for the KIP, +1 (binding) > > Ismael > > On Mon, Aug 15, 2016 at 2:20 PM, Damian Guy wrote: > > > I would like to initiate the voting process for KIP-71 ( > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 71

Re: [VOTE] KIP-75 - Add per-connector Converters

2016-08-15 Thread Sriram Subramanian
+1 (binding) On Mon, Aug 15, 2016 at 11:21 AM, Ewen Cheslack-Postava wrote: > I would like to initiate the voting process for KIP-75: > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 75+-+Add+per-connector+Converters > > I'll kick things off with a +1 (binding). > > -- > Thanks, > Ewen

Re: [ANNOUNCE] New Kafka PMC member Gwen Shapira

2016-08-17 Thread Sriram Subramanian
Congratulations Gwen! On Wed, Aug 17, 2016 at 9:24 PM, Neha Narkhede wrote: > Congratulations and welcome, Gwen! > On Wed, Aug 17, 2016 at 6:44 PM Jun Rao wrote: > > > Hi, Everyone, > > > > Gwen Shapira has been active in the Kafka community since she became a > > Kafka committer > > about a ye

Re: [VOTE] KIP-73 - Replication Quotas

2016-08-19 Thread Sriram Subramanian
I think the manual way of setting the throttling value is a good first step and definitely required when things go bad. We should continue discussing how we can build more intelligence over this incrementally. +1 (binding) On Fri, Aug 19, 2016 at 1:21 AM, Ben Stopford wrote: > I’d like to initi

Re: [ANNOUNCE] New committer: Jason Gustafson

2016-09-06 Thread Sriram Subramanian
Congratulations Jason! On Tue, Sep 6, 2016 at 3:40 PM, Vahid S Hashemian wrote: > Congratulations Jason on this very well deserved recognition. > > --Vahid > > > > From: Neha Narkhede > To: "dev@kafka.apache.org" , > "us...@kafka.apache.org" > Cc: "priv...@kafka.apache.org" > Date:

Re: [VOTE] KIP-78: Cluster Id

2016-09-06 Thread Sriram Subramanian
+1 (binding) On Tue, Sep 6, 2016 at 4:11 PM, Ismael Juma wrote: > Hi all, > > I would like to initiate the voting process for KIP-78: Cluster Id: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A+Cluster+Id > > As explained in the KIP and discussion thread, we see this as a good fi

Re: [VOTE] KIP-78 Cluster Id (second attempt)

2016-09-06 Thread Sriram Subramanian
+1 binding > On Sep 6, 2016, at 7:46 PM, Ismael Juma wrote: > > Hi all, > > I would like to (re)initiate[1] the voting process for KIP-78 Cluster Id: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A+Cluster+Id > > As explained in the KIP and discussion thread, we see this as a

Re: [DISCUSS] Time-based releases for Apache Kafka

2016-09-06 Thread Sriram Subramanian
Sounds good to me. > On Sep 6, 2016, at 8:22 PM, Jason Gustafson wrote: > > Hey All, > > It sounds like the general consensus is in favor of time-based releases. We > can continue the discussion about LTS, but I wanted to go ahead and get > things moving forward by volunteering to manage the n

Re: [DISCUSS] Kafka 0.10.1.0 Release Plan

2016-09-09 Thread Sriram Subramanian
+1 Plan looks good to me. Thanks a lot for putting this together! On Fri, Sep 9, 2016 at 3:45 PM, Jason Gustafson wrote: > Hi All, > > I've volunteered to be release manager for the upcoming 0.10.1 release and > would like to propose the following timeline: > > Feature Freeze (Sep. 19): The 0.

Re: [VOTE] 0.10.1 Release Plan

2016-09-13 Thread Sriram Subramanian
+1 (binding) > On Sep 13, 2016, at 3:03 PM, Guozhang Wang wrote: > > +1 (binding) > >> On Tue, Sep 13, 2016 at 2:53 PM, Ismael Juma wrote: >> >> +1 (binding) >> >>> On Tue, Sep 13, 2016 at 10:52 PM, Gwen Shapira wrote: >>> >>> +1 (binding) - yay for a new release! >>> >>> On Tue, Sep 13,

Re: [UPDATE] 0.10.1 Release Progress

2016-09-27 Thread Sriram Subramanian
Thanks Jason! On Tue, Sep 27, 2016 at 5:38 PM, Ismael Juma wrote: > Thanks for the update Jason. :) > > Ismael > > On Wed, Sep 28, 2016 at 1:28 AM, Jason Gustafson > wrote: > > > Hi All, > > > > Pardon all the JIRA noise, but I've been busy reducing the scope to match > > the available time sin

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

2016-10-20 Thread Sriram Subramanian
Fantastic release and on time! Congratulations everyone for our first time based release. On Thu, Oct 20, 2016 at 11:34 AM, Ismael Juma wrote: > Thanks everyone for your contributions to this release. I think it's > impressive how much has been achieved in just under 5 months. > > And special th

Re: [DISCUSS] KIP-80: Kafka REST Server

2016-10-21 Thread Sriram Subramanian
FWIW, Apache Kafka has evolved a lot from where it started. It did start as a messaging system. Over time we realized that that the vision for Kafka is to build a streaming platform and not just a messaging system. You can take a look at the site for more description about what comprises the stream

Re: [VOTE] Add REST Server to Apache Kafka

2016-10-25 Thread Sriram Subramanian
-1 for all the reasons that have been described before. This does not need to be part of the core project. On Tue, Oct 25, 2016 at 3:25 PM, Suresh Srinivas wrote: > +1. > > This is an http access to core Kafka. This is very much needed as part of > Apache Kafka under ASF governance model. This

Re: [ANNOUNCE] New committer: Jiangjie (Becket) Qin

2016-10-31 Thread Sriram Subramanian
Congratulations! On Mon, Oct 31, 2016 at 12:23 PM, Ismael Juma wrote: > Congratulations Becket. :) > > Ismael > > On 31 Oct 2016 1:44 pm, "Joel Koshy" wrote: > > > The PMC for Apache Kafka has invited Jiangjie (Becket) Qin to join as a > > committer and we are pleased to announce that he has ac

Re: [VOTE] KIP-143: Controller Health Metrics

2017-05-05 Thread Sriram Subramanian
+1 On Fri, May 5, 2017 at 6:46 AM, Tom Crayford wrote: > +1 (non-binding) > > On Fri, 5 May 2017 at 00:28, Michael André Pearce < > michael.andre.pea...@me.com> wrote: > > > +1 , really good to see better operational visibility being added to the > > broker. > > > > Sent from my iPhone > > > > >

Re: [VOTE] KIP-144: Exponential backoff for broker reconnect attempts

2017-05-05 Thread Sriram Subramanian
+1 On Fri, May 5, 2017 at 6:04 PM, Gwen Shapira wrote: > +1 > > On Fri, May 5, 2017 at 3:32 PM, Ismael Juma wrote: > > > Hi all, > > > > Given the simple and non controversial nature of the KIP, I would like to > > start the voting process for KIP-144: Exponential backoff for broker > > reconne

Re: [VOTE] KIP-153 (separating replication traffic from BytesOutPerSec metric)

2017-05-07 Thread Sriram Subramanian
+1 > On May 7, 2017, at 7:40 PM, Jun Rao wrote: > > Hi, Everyone, > > Since this is a relatively simple change, I would like to start the voting > process for KIP-153 : Include only client traffic in BytesOutPerSec metric. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-153+% > 3A+In

Re: [VOTE] KIP-133: List and Alter Configs Admin APIs (second attempt)

2017-05-07 Thread Sriram Subramanian
+1 > On May 7, 2017, at 9:01 PM, Ismael Juma wrote: > > [Seems like the original message ended up in the discuss thread in GMail, > so trying again] > > Hi everyone, > > I believe I addressed the comments in the discussion thread and given the > impending KIP freeze, I would like to start the

Re: [VOTE] KIP-154 Add Kafka Connect configuration properties for creating internal topics

2017-05-08 Thread Sriram Subramanian
+1 On Mon, May 8, 2017 at 2:14 PM, Konstantine Karantasis < konstant...@confluent.io> wrote: > +1 (non binding) > > On Mon, May 8, 2017 at 1:33 PM, Stephane Maarek < > steph...@simplemachines.com.au> wrote: > > > +1 (non binding) > > > > > > > > On 9/5/17, 5:51 am, "Randall Hauch" wrote: > > > >

Re: [VOTE] KIP-146: Isolation of dependencies and classes in Kafka Connect (restarted voting thread)

2017-05-09 Thread Sriram Subramanian
+1 On Tue, May 9, 2017 at 9:43 PM, dan wrote: > +1 (non binding) > > thanks Konstantine :thumbsup: > > On Mon, May 8, 2017 at 3:24 PM, Guozhang Wang wrote: > > > +1 > > > > On Mon, May 8, 2017 at 1:36 PM, Stephane Maarek < > > steph...@simplemachines.com.au> wrote: > > > > > +1 > > > Thanks hea

Re: [VOTE] KIP-156 Add option "dry run" to Streams application reset tool

2017-05-10 Thread Sriram Subramanian
+1 On Wed, May 10, 2017 at 9:45 AM, Neha Narkhede wrote: > +1 > > On Wed, May 10, 2017 at 12:32 PM Gwen Shapira wrote: > > > +1. Also not sure that adding a parameter to a CLI requires a KIP. It > seems > > excessive. > > > > > > On Tue, May 9, 2017 at 7:57 PM Jay Kreps wrote: > > > > > +1 > >

Re: [VOTE] KIP-151: Expose Connector type in REST API (first attempt :)

2017-05-10 Thread Sriram Subramanian
+1 On Wed, May 10, 2017 at 10:20 AM, Ewen Cheslack-Postava wrote: > +1 binding > > Thanks, > Ewen > > On Mon, May 8, 2017 at 4:54 PM, BigData dev > wrote: > > > +1 (non-binding) > > > > Thanks, > > Bharat > > > > > > On Mon, May 8, 2017 at 4:39 PM, Konstantine Karantasis < > > konstant...@confl

Re: [VOTE] KIP-155 Add range scan for windowed state stores

2017-05-10 Thread Sriram Subramanian
+1 On Wed, May 10, 2017 at 11:42 AM, Bill Bejeck wrote: > +1 > > Thanks, > Bill > > On Wed, May 10, 2017 at 2:38 PM, Guozhang Wang wrote: > > > +1. Thank you! > > > > On Wed, May 10, 2017 at 11:30 AM, Xavier Léauté > > wrote: > > > > > Hi everyone, > > > > > > Since there aren't any objections

  1   2   3   4   5   >