Re: [VOTE] KIP-372: Naming Repartition Topics for Joins and Grouping

2018-10-03 Thread Bill Bejeck
All, One additional minor change "Grouped.named" has been changed to "Grouped.as". I've updated the KIP with this change. Thanks, Bill

Re: [VOTE] KIP-369 Alternative Partitioner to Support "Always Round-Robin" Selection

2018-10-03 Thread Bill Bejeck
+1 from me. As for closing the vote, it needs to be open for a minimum of 72 and requires three binding +1 votes. Additionally, there needs more +1 binding votes than -1 votes. The description for the lazy majority vote process is described here https://cwiki.apache.org/confluence/display/KAFKA/

KIP-167 Updates

2017-09-28 Thread Bill Bejeck
All, I have updated KIP-167 to include the bootstrapping status of any GlobalKTables defined in the application. The KIP has been updated: https://cwiki.apache.org/confluence/display/KAFKA/KIP-167%3A+Add+interface+for+the+state+store+restoration+process Thanks, Bill

Re: [VOTE] KIP-171 - Extend Consumer Group Reset Offset for Stream Application

2017-10-16 Thread Bill Bejeck
+1 Thanks, Bill On Fri, Oct 13, 2017 at 6:36 PM, Ted Yu wrote: > +1 > > On Fri, Oct 13, 2017 at 3:32 PM, Matthias J. Sax > wrote: > > > +1 > > > > > > > > On 9/11/17 3:04 PM, Jorge Esteban Quilcate Otoya wrote: > > > Hi All, > > > > > > It seems that there is no further concern with the KIP-17

Re: [VOTE] KIP-205: Add all() and range() API to ReadOnlyWindowStore

2017-10-28 Thread Bill Bejeck
+1 for the KIP and +1 on renaming "range" to "fetchAll" Thanks, Bill On Thu, Oct 26, 2017 at 4:39 PM, Guozhang Wang wrote: > BTW, Xavier has an argument to rename "range" as it does not take a key or > key range at all. I'd propose we rename this function to "fetchAll". > > Guozhang > > On Wed,

Re: [VOTE] KIP-204 : adding records deletion operation to the new Admin Client API

2017-10-31 Thread Bill Bejeck
+1 Thanks, Bill On Tue, Oct 31, 2017 at 4:36 AM, Paolo Patierno wrote: > Hi all, > > > because I don't see any further discussion around KIP-204 ( > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 204+%3A+adding+records+deletion+operation+to+the+new+Admin+Client+API) > and I have alrea

Re: [DISCUSS] KIP-224: Add configuration parameters `retries` and `retry.backoff.ms` to Streams API

2017-11-09 Thread Bill Bejeck
Thanks for the KIP Matthias, +1 from me. -Bill On Thu, Nov 9, 2017 at 8:40 AM, Ted Yu wrote: > lgtm > > bq. pass both parameter > > parameter should be in plural. > Same with 'two new configuration parameter' > > Cheers > > On Thu, Nov 9, 2017 at 4:20 AM, Damian Guy wrote: > > > Thanks Matthi

Re: [DISCUSS] KIP-220: Add AdminClient into Kafka Streams' ClientSupplier

2017-11-10 Thread Bill Bejeck
I'm leaning towards option 3, although option 2 is a reasonable tradeoff between the two. Overall I'm leaning towards option 3 because: 1. As Guozhang has said we are failing "fast enough" with an Exception from the first rebalance. 2. Less complexity/maintenance cost by not having a tra

Re: [DISCUSS] KIP-224: Add configuration parameters `retries` and `retry.backoff.ms` to Streams API

2017-11-10 Thread Bill Bejeck
istration, could we > > also > > >> do > > >>> this after the rebalance callback as in the main loop? By doing this > we > > >> can > > >>> effectively swallow-and-retry-in-next-loop as we did for non-global > > >> stores.

Re: [VOTE] KIP-224: Add configuration parameters `retries` to Streams API

2017-11-13 Thread Bill Bejeck
Thanks for the KIP, +1 -Bill On Mon, Nov 13, 2017 at 7:25 PM, Ted Yu wrote: > +1 > > On Mon, Nov 13, 2017 at 4:20 PM, Matthias J. Sax > wrote: > > > Hi @all, > > > > I would like to start the vote for KIP-224: > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 224%3A+Add+config

Re: [VOTE] KIP-220: Add AdminClient into Kafka Streams' ClientSupplier

2017-11-17 Thread Bill Bejeck
+1 Thanks, Bill On Fri, Nov 17, 2017 at 12:13 PM, Colin McCabe wrote: > +1 (non-binding) > > Colin > > On Tue, Nov 14, 2017, at 10:02, Guozhang Wang wrote: > > Hello folks, > > > > I have filed a new KIP on adding AdminClient into Streams for internal > > topic management. > > > > Please review

Re: Flaky healthcheck when trying to check Kafka Stream processing app status

2017-11-29 Thread Bill Bejeck
Patrice, Thanks for reporting this. I'll have a look at what you've posted on Github. Thanks, Bill On Wed, Nov 29, 2017 at 7:04 AM, Patrice Chalcol wrote: > Hello, > > I have implemented a basic application which uses kafka streams stores and > interactive queries, available there : > https:/

Re: [DISCUSS] KIP-233: Simplify StreamsBuilder#addGlobalStore

2017-12-05 Thread Bill Bejeck
Hi Panuwat, Thanks for the KIP, overall looks good to me. I want to play the devil's advocate for a second and ask do we want to keep the older method with the extra parameters vs. deprecation? Although ATM I can't think of a good reason to keep the old method with the extra parameters. Thanks,

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

2017-12-05 Thread Bill Bejeck
Matthias, Overall I agree with what you've presented here. Initially, I was hesitant to remove information from the context of the result records (Joins or Aggregations) with the thought that when there are unexpected results, the source information would be useful for tracing back where the erro

Re: Flaky healthcheck when trying to check Kafka Stream processing app status

2017-12-06 Thread Bill Bejeck
Hi Patrice, I haven't forgotten, just sidetracked with other things. I'll get back to you by the end of the week. Thanks, Bill On Wed, Nov 29, 2017 at 10:36 AM, Bill Bejeck wrote: > Patrice, > > Thanks for reporting this. I'll have a look at what you've p

Re: [DISCUSS] KIP-210: Provide for custom error handling when Kafka Streams fails to produce

2017-12-06 Thread Bill Bejeck
Thanks for the clearly written KIP, no further comments from my end. -Bill On Wed, Dec 6, 2017 at 9:52 AM, Matt Farmer wrote: > There is already a vote thread for this KIP. I can bump it so that it’s > towards the top of your inbox. > > With regard to your concerns: > > 1) We do not have the "P

Re: [VOTE] KIP-210: Provide for custom error handling when Kafka Streams fails to produce

2017-12-06 Thread Bill Bejeck
+1 On Wed, Dec 6, 2017 at 9:54 AM, Matt Farmer wrote: > Bumping this thread so it’s visible given that the conversation on KIP-210 > has converged again. > > Current tally is 2 binding +1s, and 2 non-binding +1s. > > On November 8, 2017 at 12:26:32 PM, Damian Guy (damian@gmail.com) > wrote:

Re: [DISCUSS] KIP-228 Negative record timestamp support

2017-12-06 Thread Bill Bejeck
I'm getting to this a little late, but as for the missing timestamp semantics, it's a +1 from me for using Long.MIN_VALUE for missing timestamps for the reasons outlined by Matthias previously. Thanks, Bill On Wed, Dec 6, 2017 at 2:05 AM, Dong Lin wrote: > Sounds good. I don't think there is co

Re: Flaky healthcheck when trying to check Kafka Stream processing app status

2017-12-14 Thread Bill Bejeck
ich version of Kafka are you using for this demo app? > > > Guozhang > > On Wed, Dec 6, 2017 at 8:04 AM, Patrice Chalcol > wrote: > > > Hi Bill, > > > > Thanks, I understand. Let me know if you need further information. > > > > Regards, > &

Re: [VOTE] KIP-239 Add queryableStoreName() to GlobalKTable

2017-12-15 Thread Bill Bejeck
+1 On Fri, Dec 15, 2017 at 3:57 PM, Guozhang Wang wrote: > +1 (binding), thanks! > > On Fri, Dec 15, 2017 at 11:56 AM, Ted Yu wrote: > > > Hi, > > Here is the discussion thread: > > > > http://search-hadoop.com/m/Kafka/uyzND12QnH514pPO9?subj= > > Re+DISCUSS+KIP+239+Add+queryableStoreName+to+Glo

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

2017-12-18 Thread Bill Bejeck
of > > > > SOURCE -> KTABLESOURCE -> KTABLEFILTER -> JOIN -> SINK > > > > we build > > > > SOURCE -> KTABLEFILTER -> KTABLESOURCE -> JOIN -> SINK > > > > We should build a topology like this from the beginning and not have > > a

Re: [VOTE] KIP-243: Make ProducerConfig and ConsumerConfig constructors public

2017-12-19 Thread Bill Bejeck
+1 On Tue, Dec 19, 2017 at 12:09 PM, Guozhang Wang wrote: > +1 > > On Tue, Dec 19, 2017 at 1:49 AM, Tom Bentley > wrote: > > > +1 > > > > On 18 December 2017 at 23:28, Vahid S Hashemian < > vahidhashem...@us.ibm.com > > > > > wrote: > > > > > +1 > > > > > > Thanks for the KIP. > > > > > > --Vah

Re: [VOTE] KIP-220: Add AdminClient into Kafka Streams' ClientSupplier

2017-12-19 Thread Bill Bejeck
>>> +1 > >>> > >>> On Mon, 20 Nov 2017 at 17:52 Gwen Shapira wrote: > >>> > >>>> +1 > >>>> > >>>> Make sense. We have a supplier for every other client type :) > >>>> > >>>> On Fri, Nov 17, 2017 a

Re: KIP-244: Add Record Header support to Kafka Streams

2017-12-21 Thread Bill Bejeck
Jorge, Thanks for the KIP, I know this is a feature others in the community have been interested in getting into Kafka Streams. I took a quick pass over it, and I have one initial question. We recently reduced overloads with KIP-182, and in this KIP we are increasing them again. I can see from

Re: Vote for KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor

2017-12-26 Thread Bill Bejeck
Thanks for the KIP. +1 for me. On Tue, Dec 26, 2017 at 6:22 PM Ted Yu wrote: > +1 from me as well. > > On Tue, Dec 26, 2017 at 10:41 AM, Matthias J. Sax > wrote: > > > Thanks for the KIP Boyang! > > > > I don't have any further comments. > > > > +1 from me. > > > > @Ted: This is a rather simpl

Re: [VOTE] KIP-233: Simplify StreamsBuilder#addGlobalStore

2017-12-27 Thread Bill Bejeck
+1 On Wed, Dec 27, 2017 at 3:07 PM, Matthias J. Sax wrote: > +1 > > On 12/26/17 9:00 PM, Panuwat Anawatmongkhon wrote: > > Hi all, > > I would like to start the vote thread. > > This is link for the kip. > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-233%3A+Simplify+ > StreamsBuil

Re: [VOTE] KIP-420: Add Single Value Fetch in Session Stores

2019-01-21 Thread Bill Bejeck
Thanks for the KIP Guozhang, +1 for me. -Bill On Sat, Jan 19, 2019 at 1:59 PM Matthias J. Sax wrote: > Thanks for the KIP Guozhang! > > Would it make sense to add a default implementation for the new method? > I am not sure, and I actually think it would not make sense: > > - Kafka Streams pro

Re: [VOTE] KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers

2019-02-05 Thread Bill Bejeck
Thanks for the KIP, Rohan. +1 (non-binding). -Bill On Tue, Feb 5, 2019 at 1:24 PM Manikumar wrote: > +1 (binding). Thanks for the KIP. > > On Tue, Feb 5, 2019 at 10:01 AM Gwen Shapira wrote: > > > Thanks for the KIP. > > +1 > > > > On Mon, Feb 4, 2019 at 1:56 PM Rohan Desai > > wrote: > > >

Re: [ANNOUNCE] New Committer: Randall Hauch

2019-02-14 Thread Bill Bejeck
Congrats Randall! -Bill On Thu, Feb 14, 2019 at 9:17 PM Guozhang Wang wrote: > Hello all, > > The PMC of Apache Kafka is happy to announce another new committer joining > the project today: we have invited Randall Hauch as a project committer and > he has accepted. > > Randall has been particip

Re: [VOTE] KIP-428: Add in-memory window store

2019-02-20 Thread Bill Bejeck
Hi Sophie, Thanks for the KIP! My apologies for the delay in voting. +1(binding) -Bill On Thu, Feb 14, 2019 at 8:59 PM Guozhang Wang wrote: > +1 (binding). > > On Thu, Feb 14, 2019 at 4:07 PM Matthias J. Sax > wrote: > > > +1 (binding) > > > > > > -Matthias > > > > On 2/14/19 3:36 PM, Sophie

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

2019-02-21 Thread Bill Bejeck
Thanks for the KIP Boyang. +1(binding) -Bill On Thu, Feb 21, 2019 at 12:31 PM Boyang Chen wrote: > Oh, good catch Guozhang. I just renamed the function to `sessionedTable` > to be consistent, thanks! > > > From: Guozhang Wang > Sent: Friday, February 22, 2019 1

Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL

2019-02-21 Thread Bill Bejeck
; > > > > This contradict the non-naming of stores from the very beginning. > > > > > > Also, the KIP still contains the question about `join(GlobalKTable, > > KeyValueMapper, ValueJoiner)` and `leftJoin(GlobalKTable, > > KeyValueMapper, ValueJoiner)`. I

Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL

2019-02-26 Thread Bill Bejeck
o that it will be much easier > to review. > > Thanks > > Le jeu. 21 févr. 2019 à 23:54, Bill Bejeck a écrit : > > > Hi Florian, > > > > Overall the KIP LGTM. Once you've addressed the final comments from > > Matthias I think we can put this

Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL

2019-02-26 Thread Bill Bejeck
, and it also creates more ambiguity in the API, since there are > >> then multiple ways to say the same thing. > >> > >> Maybe in the future, if there's some automatic default configuration for > >> suppression, then we can add `as(name)`, but

Re: [VOTE] KIP-307: Allow to define custom processor names with KStreams DSL

2019-02-27 Thread Bill Bejeck
t;>> comment on it regarding the newly added APIs. Could you take a look? If > >>>>> that makes sense could you update the wiki page to make sure we have > >> all > >>>>> the relevant public API changes. > >>>>> > >>>&

Re: [VOTE] KIP-307: Allow to define custom processor names with KStreams DSL

2019-02-27 Thread Bill Bejeck
t;>>> On Thu, Jan 17, 2019 at 5:04 PM Guozhang Wang > > >> wrote: > > >>>> > > >>>>> Hello Florian, > > >>>>> > > >>>>> Thanks for the writeup! I made a pass on the wiki page itself and > >

Re: [VOTE] 2.2.0 RC2

2019-03-20 Thread Bill Bejeck
+1 (non-binding) - Validated signature - build from source and ran tests (all passed) - verified the quick start and Kafka Streams quick start On Sat, Mar 9, 2019 at 5:56 PM Matthias J. Sax wrote: > Hello Kafka users, developers and client-developers, > > This is the third candidate for release

[DISCUSSION] KIP-418: A method-chaining way to branch KStream

2019-03-21 Thread Bill Bejeck
All, I'd like to jump-start the discussion for KIP- 418. Here's the original message: Hello, I'd like to start a discussion about KIP-418. Please take a look at the KIP if you can, I would appreciate any feedback :) KIP-418: https://cwiki.apache.org/confluence/display/KAFKA/KIP-418%3A+A+metho

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

2019-03-21 Thread Bill Bejeck
predicate1, predicate2); branches[0].filter().mapValues(...).. branches[1].selectKey(...).groupByKey(). Thanks! Bill On Thu, Mar 21, 2019 at 6:15 PM Bill Bejeck wrote: > All, > > I'd like to jump-start the discussion for KIP- 418. > > Here's the original message:

Re: [VOTE] KIP-422: Use the default value of max.poll.interval in Streams

2019-03-27 Thread Bill Bejeck
+1 for me, Thanks, Bill On Wed, Mar 27, 2019 at 4:13 PM Guozhang Wang wrote: > +1 from me. > > Though note that we cannot make such changes in older versions since even > if we release new versions out of those branches they are considered > bug-fix only and hence should not have any interface

Re: [VOTE] KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics

2019-03-29 Thread Bill Bejeck
Thanks for the KIP, +1 (binding) -Bill On Fri, Mar 29, 2019 at 12:42 PM Mickael Maison wrote: > +1 (non binding) > For consistency, should we also set retention.ms to -1 instead of > Long.MAX_VALUE? > > On Fri, Mar 29, 2019 at 3:59 PM Manikumar > wrote: > > > > +1 (binding) > > > > Thanks fo

Re: Add Jira permission and wiki permission

2019-04-01 Thread Bill Bejeck
Hi, You're already in Jira as a contributor, but I can't seem to find you in the Apache Confluence (https://cwiki.apache.org/confluence) can you confirm your account there? Thanks, Bill On Mon, Apr 1, 2019 at 1:42 AM slim ouertani wrote: > Hello, > > user id: ouertani > > Thanks in advance. >

Re: Contributor subscription request

2019-04-01 Thread Bill Bejeck
Hi Anurag, No problem we'll just need your Apache Jira user id to get you added. Thanks, Bill On Sun, Mar 31, 2019 at 3:29 PM Anurag Saxena wrote: > Hi, > > Please add me to kafka contributor list so that I can start fixing Kafka > bugs and raise PRs. > > Regards, > Anurag. >

Re: Add Jira permission and wiki permission

2019-04-04 Thread Bill Bejeck
> On Mon, Apr 1, 2019 at 4:49 PM Bill Bejeck wrote: > > > Hi, > > > > You're already in Jira as a contributor, but I can't seem to find you in > > the Apache Confluence (https://cwiki.apache.org/confluence) can you > > confirm > > your account

Re: [DISCUSS] KIP-445: In-memory Session Store

2019-04-08 Thread Bill Bejeck
Hi Sophie, Thanks for the KIP, it's a +1 from me. -Bill On Tue, Apr 2, 2019 at 1:09 AM Guozhang Wang wrote: > Hello Sophie, > > Thanks for the KIP, I've made a pass on it and it lgtm. > > > Guozhang > > On Fri, Mar 29, 2019 at 5:32 PM Sophie Blee-Goldman > wrote: > > > Hello all, > > > > This

Re: [VOTE] KIP-445: In-memory session store

2019-04-09 Thread Bill Bejeck
Thanks for the KIP Sophie. +1(binding) -Bill On Tue, Apr 9, 2019 at 12:14 AM Matthias J. Sax wrote: > Thanks for the KIP Sophie! > > +1 (binding) > > > -Matthias > > On 4/8/19 5:26 PM, Sophie Blee-Goldman wrote: > > Hello all, > > > > There has been a positive reception so I'd like to call for

Re: Request KIP Permissions

2019-04-11 Thread Bill Bejeck
Done On Thu, Apr 11, 2019 at 8:40 AM Łukasz Antoniak wrote: > Hi, > > Could you please grant me write access to KIP proposals? I intend to make > progress on KAFKA-6393. Wiki ID: lukasz (apache.org). > > Best regards, > Lukasz Antoniak >

Re: [DISCUSS] KIP-450: Sliding Window Aggregations in the DSL

2019-04-12 Thread Bill Bejeck
Thanks for the KIP Sophie. I have a couple of additional comments. The current proposal only considers stream-time. While I support this, each time we introduce a new operation based on stream-time, invariably users request that operation support wall-clock time as well. Would we want to consid

Re: [DISCUSS] KIP-446: Add changelog topic configuration to KTable suppress

2019-04-12 Thread Bill Bejeck
Thanks for the KIP Maarten. I also agree that keeping the `withLoggingDisabled()` and `withLoggingEnabled(Map)` methods is the better option. When it comes to educating the users on the downside of disabling logging, IMHO I think a comment in the JavaDoc should be sufficient. -Bill On Fri, Apr

Re: Request KIP Permissions

2019-04-16 Thread Bill Bejeck
You're all set now! I look forward to your KIP. Thanks, Bill On Tue, Apr 16, 2019 at 1:15 AM Jukka Karvanen wrote: > Hi, > > Could you please grant me write access to KIP proposals? > I am planning to make KIP for KAFKA-8233: Helper class to make it simpler > to write test logic with TopologyT

Re: [VOTE] KIP-446: Add changelog topic configuration to KTable suppress

2019-04-17 Thread Bill Bejeck
Thanks for the KIP. +1(binding) -Bill On Wed, Apr 17, 2019 at 12:58 PM Bruno Cadonna wrote: > Hi Maarten Duijn, > > Thank you for driving this. > > +1 (non-binding) > > Best, > Bruno > > On Wed, Apr 17, 2019 at 8:21 AM Maarten Duijn > wrote: > > > Hello all, > > > > There has been informal ag

Re: New Contributor Request

2019-04-18 Thread Bill Bejeck
Brandt, You should be all set now. -Bill On Thu, Apr 18, 2019 at 3:36 PM Newton, Brandt (CAI - Burlington) < brandt.new...@coxautoinc.com> wrote: > Hello, > > I’d like to contribute to Kafka. Can someone please add me as a > contributor to JIRA so I can assign an issue to myself? My username is

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

2019-04-18 Thread Bill Bejeck
Congrats Matthias! Well deserved! -Bill On Thu, Apr 18, 2019 at 5:35 PM Guozhang Wang wrote: > Hello Everyone, > > I'm glad to announce that Matthias J. Sax is now a member of Kafka PMC. > > Matthias has been a committer since Jan. 2018, and since then he continued > to be active in the communi

Re: Requesting access to create KIPs

2019-04-23 Thread Bill Bejeck
Alex, you are all set now. -Bill On Tue, Apr 23, 2019 at 1:32 PM Alex Liu wrote: > Hello, > > I would like to have permissions to create content in this page: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals > My wiki user is "alexliu". > > Thanks, > Alex >

Re: [DISCUSS] KIP-462 : Use local thread id for KStreams

2019-04-30 Thread Bill Bejeck
Thanks for the KIP Boyang. I have no additional comments from the ones already presented. +1(binding) -Bill On Tue, Apr 30, 2019 at 4:35 PM Boyang Chen wrote: > Thank you Guozhang! > > > From: Guozhang Wang > Sent: Wednesday, May 1, 2019 3:54 AM > To: dev@kaf

Re: [VOTE] KIP-462 : Use local thread id for KStreams

2019-05-01 Thread Bill Bejeck
+1(binding) On Wed, May 1, 2019 at 3:07 AM Matthias J. Sax wrote: > +1 (binding) > > > -Matthias > > On 4/26/19 6:16 AM, Boyang Chen wrote: > > Hey friends, > > > > I would like to start the vote for KIP-462: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-462%3A+Use+local+thread+id+

Re: [VOTE] KIP-453: Add close() method to RocksDBConfigSetter

2019-05-06 Thread Bill Bejeck
Thanks for the KIP Sophie. +1(binding) On Mon, May 6, 2019 at 4:51 PM John Roesler wrote: > Thanks, Sophie, I reviewed the KIP, and I agree this is the best / > only-practical approach. > > +1 (non-binding) > > On Mon, May 6, 2019 at 2:23 PM Matthias J. Sax > wrote: > > > +1 (binding) > > > >

Re: Apply for JIRA contributor permission

2019-05-08 Thread Bill Bejeck
Done. Thanks for contributing! -Bill On Wed, May 8, 2019 at 11:15 AM Kengo Seki wrote: > Hi, > > I just filed KAFKA-8337 and would like to assign it to myself. > Would you add me to the contributors list? > My username is "sekikn". > > Thanks in advance! > > Kengo Seki >

Re: [VOT] KIP-449: Add connector contexts to Connect worker logs (vote thread)

2019-05-09 Thread Bill Bejeck
+1 (binding) Makes a lot of sense to me. -Bill On Thu, May 9, 2019 at 2:05 PM Gwen Shapira wrote: > +1 (binding) > Hell yeah! > > On Mon, Apr 29, 2019 at 3:34 PM Randall Hauch wrote: > > > I would like to start the vote for KIP-258: > > > > > > > https://cwiki.apache.org/confluence/display/KAF

Re: Please give me permission to create KIP,Thanks!

2019-05-13 Thread Bill Bejeck
Responding here on the dev list as well. Thanks for your interest in contributing! You should be all set now. Thanks, Bill On Mon, May 13, 2019 at 12:34 PM hu xiaohua wrote: > > I want create my KIP ,but I havn't a permission,please give me permission > to create KIP,My Wiki ID is Flowermin.T

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

2019-05-20 Thread Bill Bejeck
Hi Bruno, Thanks for the KIP, this will be a useful addition. Overall the KIP looks good to me, and I have two minor comments. 1. For the tags should, I'm wondering if rocksdb-state-id should be rocksdb-store-id instead? 2. With the compaction metrics, would it be possible to add total compacti

Re: Contributor

2019-05-20 Thread Bill Bejeck
Hi, Thanks for your interest in contributing to Apache Kafka. You should be all set now. Thanks, Bill On Mon, May 20, 2019 at 2:31 PM wrote: > Hi, > > > > I want to contribute to Apache Kafka. > > Would you please give me the contributor permission? > > My JIRA ID is shark.chen. > > > >

Re: Permission to create KIP

2019-05-30 Thread Bill Bejeck
Hi Ivan, Thanks for your interest in Apache Kafka. You should be all set now. Thanks, Bill On Thu, May 30, 2019 at 10:34 AM Ivan Yurchenko wrote: > Hi, > > I'd like to be able to create KIPs. Could someone please set up the > permissions for me? The username is ivanyu . > Thanks! > > Ivan >

Re: Request for Contributor Permissions

2019-06-03 Thread Bill Bejeck
Hi, You're all set now! Thanks for your interest in Apache Kafka. -Bill On Mon, Jun 3, 2019 at 4:30 AM John Park <87johnpar...@gmail.com> wrote: > Hi, > > My name is In Park and I would like to contribute to Apache Kafka. > Could you give me contributor permissions? > My Jira ID is : in-park

Re: [JIRA] KAFKA-7760

2019-06-06 Thread Bill Bejeck
Hi Dulvin, Thanks for your interest in Apache Kafka. I've assigned KAFKA-7760 to you. I've also added you to the contributors list so in the future you can assign tickets yourself tickets. Thanks, Bill On Thu, Jun 6, 2019 at 8:17 AM Dulvin Witharane wrote: > Please assign the above to me. >

Re: Contributor permissions

2019-06-07 Thread Bill Bejeck
Hi Carlos, Thanks again for your interest in Apache Kafka. I've added you as a contributor so you can now self-assign tickets. -Bill On Fri, Jun 7, 2019 at 6:14 AM Carlos Manuel Duclos-Vergara < carlos.duc...@schibsted.com> wrote: > Hi, > Yes, I read the guidelines. I forgot to mention the JIR

Re: JIRA Contributor permissions

2019-06-07 Thread Bill Bejeck
Vikash, Thanks for your interest in Apache Kafka. You're all set now. -Bill On Fri, Jun 7, 2019 at 12:45 PM Vikash Kumar wrote: > Sorry I forgot to mention my user ID. > > My User ID : krvikash > > On Fri, Jun 7, 2019 at 10:12 PM Vikash Kumar > wrote: > > > Hi, > > > > I want to start contri

Re: Requesting contributor permissions

2019-06-13 Thread Bill Bejeck
Igor, Thanks for your interest in Apache Kafka. You're all set now. -Bill On Thu, Jun 13, 2019 at 1:36 PM Igor Soarez wrote: > JIRA username: soarez > GitHub username: soarez > > Looking to assign https://issues.apache.org/jira/browse/KAFKA-8526 to > myself > > -- > Igor Soarez >

Re: Contributor Permissions

2019-06-13 Thread Bill Bejeck
Mark, Thanks for your interest in Apache Kafka. You're in the contributors list now. Thanks, Bill On Thu, Jun 13, 2019 at 1:37 PM Mark Cox wrote: > Hello AK, > > Could I gain contributor permissions for the Apache Kafka project please? > > My GitHub ID is "MarkC0x" (note the zero) > > Cheers

Re: Request for Contributor Permissions

2019-06-18 Thread Bill Bejeck
Hi Thomas, You're all set now. Thanks, Bill On Tue, Jun 18, 2019 at 8:41 PM Thomas Zhou wrote: > Hi, > > I want to contribute to Kafka, could you please give me contributor > permission? > My Jira id is - thomas930410 > > > Thanks, > Thomas

Re: Become a contributer

2019-06-18 Thread Bill Bejeck
Hi Anastasia, Thanks for your interest in Apache Kafka. You're all set now. -Bill On Mon, Jun 17, 2019 at 4:36 PM Anastasia Vela wrote: > My user ID is anastasiavela. > > Anastasia > > On Thu, Jun 13, 2019 at 11:18 AM Anastasia Vela > wrote: > > > Hi, > > > > I would like to contribute to Ap

[DISCUSS] KIP-479: Add Materialized to Join

2019-06-18 Thread Bill Bejeck
All, I'd like to start a discussion for adding a Materialized configuration object to KStream.join for naming state stores involved in joins. https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+Materialized+to+Join Your comments and suggestions are welcome. Thanks, Bill

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

2019-06-19 Thread Bill Bejeck
Hi Bruno, Just getting caught up on this KIP thread. Looks good to me, and I don't have any additional comments to what's already been presented. Thanks, Bill On Wed, Jun 19, 2019 at 1:42 PM Bruno Cadonna wrote: > John and Guozhang, > > thank you for your comments. > > @Guozhang could you ple

Re: [VOTE] KIP-471: Expose RocksDB Metrics in Kafka Streams

2019-06-19 Thread Bill Bejeck
+1 (binding) Thanks, Bill On Wed, Jun 19, 2019 at 1:19 PM John Roesler wrote: > I'm +1 (nonbinding) > > Thanks! > -John > > On Tue, Jun 18, 2019 at 7:48 AM Bruno Cadonna wrote: > > > > Hi, > > > > I would like to start the voting on KIP-471: > > > https://cwiki.apache.org/confluence/display/KA

Re: [VOTE] KIP-474: To deprecate WindowStore#put(key, value)

2019-06-20 Thread Bill Bejeck
Sorry for being late to the party. I've reviewed the KIP and it's a great step in the right direction. +1 (binding) Thanks, Bill On Thu, Jun 20, 2019 at 11:42 AM John Roesler wrote: > Not that it changes the outcome, but I'm also +1 (nonbinding). > > Been wanting to do this for a while, thank

Re: [DISCUSS] KIP-470: TopologyTestDriver test input and output usability improvements

2019-06-21 Thread Bill Bejeck
Jukka, Thanks for the KIP. I like the changes overall. One thing I wanted to confirm, and this may be me being paranoid, but will the changes for input/output topic affect how the TopologyTestDriver works with internal topics when there are sub-topologies created? On Fri, Jun 21, 2019 at 12:05 PM

Re: [DISCUSS] KIP-479: Add Materialized to Join

2019-06-22 Thread Bill Bejeck
nder option 2 above, this behavior would > > change to NOT provision a state store and instead just consult the > > ValueGetter. To get back to the current behavior, users would have to > > add a "bytes store supplier" to the Materialized to indicate that, > > y

Re: [DISCUSS] KIP-470: TopologyTestDriver test input and output usability improvements

2019-06-24 Thread Bill Bejeck
proposed). > > > > > > (2) `TopologyTestDriver#createInputTopic`: might it be worth to add > > overload to initialize the timetamp and auto-advance feature directly? > > Otherwise, uses always need to call `configureTiming` as an extra call? > > > > > &

Re: Contribution access to Kafka Confluence page

2019-06-25 Thread Bill Bejeck
Hi Anastasia, You're all set now! -Bill On Tue, Jun 25, 2019 at 1:50 PM Anastasia Vela wrote: > Hi, > > Could I get access to create KIPs on the Kafka Confluence page? > Email: av...@confleunt.io > UserID: avela > > Thanks, > Anastasia >

Re: [DISCUSS] KIP-478 Strongly Typed Processor API

2019-06-28 Thread Bill Bejeck
Sorry for coming late to the party. As for the naming I'm in favor of RecordProcessor as well. I agree that we should not take on doing all of the package movements as part of this KIP, especially as John has pointed out, it will be an opportunity to discuss some clean-up on individual classes wh

Re: PR builds stopped since 07/10 11AM

2019-07-11 Thread Bill Bejeck
Thanks Ismael! On Thu, Jul 11, 2019 at 10:41 AM Ismael Juma wrote: > Hi all, > > After updating some jobs to the "modern" PR builder, I noticed several > regressions and shared the details in the Apache Builds mailing list. > Thankfully, the team has re-enabled the old PR builder. I have reverte

Re: [DISCUSS] KIP-479: Add Materialized to Join

2019-07-11 Thread Bill Bejeck
gt;>> * the WindowStore itself is fine, if overly broad, > >>>> since the only two methods we need are `window.put(key, value, > >>>> context().timestamp())` and `WindowStoreIterator iter = > >>>> window.fetch(key, timeFrom, timeTo)`. > >>>>

Re: Requesting Contributor Permissions

2019-07-12 Thread Bill Bejeck
Hi Manish, If you do a search for tasks with the label "newbie" you'll find tickets that are great for making your first contribution(s) Thanks, Bill On Fri, Jul 12, 2019 at 11:39 AM Manish G wrote: > Hi all, > > I am a newbie here, so not sure if I can work on tickets straightaway. But > if s

Re: [VOTE] KIP-488: Clean up Sum,Count,Total Metrics

2019-07-12 Thread Bill Bejeck
Thanks for the KIP, seems like a good change. +1 (binding) -Bill On Fri, Jul 12, 2019 at 2:47 PM Bruno Cadonna wrote: > Hi John, > > +1 (non-binding) > > Best, > Bruno > > On Fri, Jul 12, 2019 at 8:45 PM John Roesler wrote: > > > > Hi Kafka devs, > > > > Yesterday, I proposed KIP-488 as a min

Re: [DISCUSS] KIP-488: Clean up Sum,Count,Total Metrics

2019-07-16 Thread Bill Bejeck
Hi John, Thanks for the updates. I like RunningCount and RunningSum. What about WindowedCount, WindowedSum instead of Moving? I'm just throwing this out there as Windowed seems more intuitive to me, but I'm not married to the idea. -Bill On Tue, Jul 16, 2019 at 5:09 PM John Roesler wrote: >

Re: [DISCUSS] KIP-488: Clean up Sum,Count,Total Metrics

2019-07-17 Thread Bill Bejeck
personally fine with either `MovingXxx`, > > `WindowedXxx`, or `RunningXxx` -- to me, that are all equally good to > > describe the semantics. > > > > > > > > -Matthias > > > > > > > > On 7/16/19 2:25 PM, Sophie Blee-Goldman wrot

Re: Add to contribution list

2019-07-17 Thread Bill Bejeck
Thanks for your interest in Apache Kafka. You're all set with Jira, but I couldn't find your user name in the wiki. The wiki requires a separate username creation. Can you add yourself there and ping the list again and we'll get you added. Thanks, Bill On Wed, Jul 17, 2019 at 6:42 AM Omar Al-Sa

Re: [DISCUSS] KIP-479: Add Materialized to Join

2019-07-17 Thread Bill Bejeck
as > previously derailed this KIP discussion. In the interest of just > closing the gap and keeping the API change small, it seems better to > just go with documentation for now. > > Thanks again, > -John > > On Thu, Jul 11, 2019 at 2:45 PM Bill Bejeck wrote: > > > &g

Re: Add to contribution list

2019-07-17 Thread Bill Bejeck
s again! > Omar > > On Wed, 17 Jul 2019 at 19:06, Bill Bejeck wrote: > > > Thanks for your interest in Apache Kafka. > > > > You're all set with Jira, but I couldn't find your user name in the wiki. > > The wiki requires a separate username creation. >

Re: [VOTE] KIP-488: Clean up Sum,Count,Total Metrics

2019-07-17 Thread Bill Bejeck
+1 (binding) for the updated KIP. On Wed, Jul 17, 2019 at 4:09 PM John Roesler wrote: > Hey, Bruno and Bill, > > Since you cast your votes before the KIP was updated, do you mind > re-casting just so we can be sure you're still in favor? > > Thanks, > -John > > On Wed, Jul 17, 2019 at 2:01 PM Gu

Re: [VOTE] KIP-480 : Sticky Partitioner

2019-07-19 Thread Bill Bejeck
Thanks for the KIP, looks like a great addition. +1 (binding) -Bill On Fri, Jul 19, 2019 at 5:55 AM Mickael Maison wrote: > +1 (non binding) > Thanks for the KIP! > > On Fri, Jul 19, 2019 at 2:23 AM David Arthur > wrote: > > > > +1 binding, looks like a nice improvement. Thanks! > > > > -Davi

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

2019-07-19 Thread Bill Bejeck
Hi Lavani, Thanks for resurrecting this KIP. I'm also a +1 for adding a partition option. In addition to the reason provided by John, my reasoning is: 1. Users may want to use something other than hash-based partitioning 2. Users may wish to partition on something different than the key

Re: [VOTE] KIP-466: Add support for List serialization and deserialization

2019-07-24 Thread Bill Bejeck
Thanks for the KIP looks to be very helpful. +1(binding) -Bill On Wed, Jul 24, 2019 at 5:01 PM Guozhang Wang wrote: > +1 (binding). > > Thanks Daniyar! > > On Wed, Jul 24, 2019 at 12:04 PM John Roesler wrote: > > > Thanks, Daniyar, > > > > I'm +1 (nonbinding) > > > > -John > > > > On Tue, Jun

[VOTE] KIP-479 Add Materialized to Join

2019-07-25 Thread Bill Bejeck
All, After a great discussion on KIP-479 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+Materialized+to+Join) I'd like to start a vote. Thanks, Bill

Re: [VOTE] KIP-467: Augment ProduceResponse error messaging

2019-07-29 Thread Bill Bejeck
Hi Guozang, Thanks for the KIP, looks like a great improvement. +1 for me. -Bill On Fri, Jul 26, 2019 at 8:18 PM Jun Rao wrote: > Hi, Guozhang, > > Thanks for the KIP. +1 > > Jun > > On Fri, Jul 26, 2019 at 4:40 PM Jason Gustafson > wrote: > > > Hi Guozhang, > > > > I agree it is misleading

Re: [VOTE] KIP-478 Strongly Typed Streams Processor API

2019-07-29 Thread Bill Bejeck
Thanks for the KIP. +1 (binding) -Bill On Wed, Jul 24, 2019 at 12:12 PM Guozhang Wang wrote: > Yeah I think I agree with you. > > +1 (binding) from me. > > > Guozhang > > > On Wed, Jul 24, 2019 at 7:43 AM John Roesler wrote: > > > Hi Guozhang, > > > > Thanks! I just replied in the discuss thr

Re: JIRA and KIP contributor permissions

2019-07-30 Thread Bill Bejeck
Thanks for your interest in Apache Kafka. You should be set now. Thanks, Bill On Tue, Jul 30, 2019 at 9:40 AM Gokul Ramanan Subramanian < gokul24...@gmail.com> wrote: > Hello Community, > > In order to start contributing to Apache Kafka project, could I please > request contributor access to JI

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

2019-07-30 Thread Bill Bejeck
Thanks for the KIP Levani. +1 (binding) -Bill On Tue, Jul 30, 2019 at 3:37 PM Levani Kokhreidze wrote: > Hello, > > Still waiting for feedback on this KIP. > Please let me know if you have any concerns and/or questions. > > Regards, > Levani > > > > On Jul 24, 2019, at 8:20 PM, Sophie Blee-Gol

Re: [DISCUSS] KIP-470: TopologyTestDriver test input and output usability improvements

2019-08-01 Thread Bill Bejeck
from `long` for timestamps to `Instant` and > > > > `Duration` ? > > > >> This version startTimestamp is Instant and autoAdvance Duration in > > > > Initialization and with manual configured collection pipe methods. > > > >> Now timestamp of TestRecord is

Re: [VOTE] KIP-479 Add Materialized to Join

2019-08-02 Thread Bill Bejeck
ul 29, 2019 at 6:03 PM Guozhang Wang wrote: > +1 (binding) > > On Thu, Jul 25, 2019 at 7:39 PM Matthias J. Sax > wrote: > > > +1 (binding) > > > > On 7/25/19 1:05 PM, Bill Bejeck wrote: > > > All, > > > > > > After a great discussion on

<    1   2   3   4   5   6   7   8   9   10   >