[jira] [Created] (KAFKA-9976) Aggregates should reuse repartition nodes

2020-05-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9976: -- Summary: Aggregates should reuse repartition nodes Key: KAFKA-9976 URL: https://issues.apache.org/jira/browse/KAFKA-9976 Project: Kafka Issue Type: Improvement

Re: Request for permission to create KIP

2020-04-27 Thread Bill Bejeck
Done. Thanks, Bill On Mon, Apr 27, 2020 at 11:05 AM Wang (Leonard) Ge wrote: > Hi, > > I'd like to request permission to create KIP. My email address is: > w...@confluent.io. > > Thanks! > > -- > Leonard Ge > Software Engineer Intern - Confluent >

Re: [VOTE] KIP-594: Expose output topic names from TopologyTestDriver

2020-04-23 Thread Bill Bejeck
Hi Andy, Thanks for the KIP. It's a + 1(binding) for me. -Bill On Thu, Apr 23, 2020 at 9:45 AM John Roesler wrote: > Hi Andy, > > I just took another look, and it looks good to me! Thanks for the > contribution. > > I’m +1 (binding) > > -John > > On Thu, Apr 23, 2020, at 06:49, Andy Coates

Re: Permission to self-assign tickets

2020-04-21 Thread Bill Bejeck
Done. Thanks for your interest in Apache Kafka. -Bill On Tue, Apr 21, 2020 at 11:05 AM 无名 wrote: > Hi Kafka dev team, > > > I am wondering if you can grant me the permission to self-assign tickets? > > > My username iszhaohaidao and email is zhaohaidao2...@foxmail.com > > > Thanks.

Re: Permission to self-assign tickets

2020-04-20 Thread Bill Bejeck
Hi Leonard, You should be all set now. -Bill On Mon, Apr 20, 2020 at 11:09 AM Wang (Leonard) Ge wrote: > Hi Kafka dev team, > > > I am wondering if you can grant me the permission to self-assign tickets? > > My user name is: gw524119574 and email is w...@confluent.io > > Thanks in advance for

Re: [ANNOUNCE] Apache Kafka 2.5.0

2020-04-15 Thread Bill Bejeck
me streaming applications that transform or react > > to the streams of data. > > > > > > Apache Kafka is in use at large and small companies worldwide, including > > Capital One, Goldman Sachs, ING, LinkedIn, Netflix, Pinterest, Rabobank, > > Target, The New York Tim

Re: [kafka-clients] Re: [VOTE] 2.5.0 RC3

2020-04-10 Thread Bill Bejeck
Hi David, +1 (non-binding) Verified signatures, built jars from source, ran unit and integration tests, all passed. Thanks for running the release. -Bill On Wed, Apr 8, 2020 at 10:10 AM David Arthur wrote: > Passing Jenkins build on 2.5 branch: >

[jira] [Created] (KAFKA-9798) org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

2020-04-01 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9798: -- Summary: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses Key: KAFKA-9798 URL: https://issues.apache.org/jira/browse/KAFKA-9798

Re: Request Permission to Create KIP

2020-03-30 Thread Bill Bejeck
Hi Xiaodong, You're all set now. Thanks for your interest in Apache Kafka. Regards, Bill On Mon, Mar 30, 2020 at 12:40 PM Xiaodong Du wrote: > Hi, > > I’d like to submit a KIP and am requesting access to the wiki page. My wiki > ID is xiaodongdu2008. Please let me know if anything else is

[ANNOUNCE] Apache Kafka 2.4.1

2020-03-12 Thread Bill Bejeck
, Yelp, and Zalando, among others. A big thank you for the following 35 contributors to this release! A. Sophie Blee-Goldman, Alex Kokachev, bill, Bill Bejeck, Boyang Chen, Brian Bushree, Brian Byrne, Bruno Cadonna, Chia-Ping Tsai, Chris Egerton, Colin Patrick McCabe, David Jacot, David Kim, David Mao

Re: Create KIP permissions

2020-03-12 Thread Bill Bejeck
Hi Paolo, You're all set now. Thanks, Bill On Thu, Mar 12, 2020 at 9:54 AM Paolo Moriello wrote: > Hi, > > My name is Paolo Moriello, I'd like to get permissions to create KIPs. My > wiki id is: paolomoriello. > > Thanks, > Paolo >

Re: [kafka-clients] Re: [VOTE] 2.5.0 RC1

2020-03-12 Thread Bill Bejeck
Hi David, 1. Scanned the Javadoc, looks good 2. Downloaded kafka_2.12-2.5.0 and ran the quickstart and streams quickstart 3. Verified the signatures +1 (non-binding) Thanks for running the release David! -Bill On Tue, Mar 10, 2020 at 4:01 PM David Arthur wrote: > Thanks for the

[RESULTS] [VOTE] Release Kafka version 2.4.1 UPDATE

2020-03-11 Thread Bill Bejeck
Previously I erroneously reported the vote with 4 PMC +1s. I thought one of the voters was also a PMC member. But since there are still 3 PMC + 1s, the passing vote for this release is still valid. This vote passes with 10 +1 votes (3 bindings) and no 0 or -1 votes. +1 votes PMC Members (in

[RESULTS] [VOTE] Release Kafka version 2.4.1

2020-03-10 Thread Bill Bejeck
* Levani Kokhreidze Vote thread: https://www.mail-archive.com/dev@kafka.apache.org/msg105496.html I'll continue with the release process, and the release announcement will follow in the next few days. Bill Bejeck

Re: Subject: [VOTE] 2.4.1 RC0

2020-03-10 Thread Bill Bejeck
ths and no-one > noticed? 2.4.1 seemingly has all the votes needed for the release. Why not > go ahead with it. When KAFKA-9675 is merged, it can be included in the next > release. > > Ismael > > On Mon, Mar 9, 2020 at 8:43 PM Bill Bejeck wrote: > > > Thanks to everyone for

Re: Subject: [VOTE] 2.4.1 RC0

2020-03-09 Thread Bill Bejeck
> > > > com ( > > > > > >>> eno.there...@gmail.com ) > > > > > > >>> > > > > > >>> > > > > > >> > > > > > >> > > > > > >> > >

Re: 回复:回复:[Vote] KIP-571: Add option to force remove members in StreamsResetter

2020-03-05 Thread Bill Bejeck
Thanks for the KIP. +1 (binding). -Bill On Wed, Mar 4, 2020 at 12:40 AM Guozhang Wang wrote: > Thanks, +1 from me (binding). > > On Tue, Mar 3, 2020 at 9:39 PM feyman2009 wrote: > > > Hi, Guozhang > > Thanks a lot for the advice, that make sense! > > I have updated the KIP page

Subject: [VOTE] 2.4.1 RC0

2020-03-02 Thread Bill Bejeck
/system-test-kafka/job/2.4/152/ Thanks, Bill Bejeck

Re: [ANNOUNCE] New committer: Konstantine Karantasis

2020-02-26 Thread Bill Bejeck
Congratulations Konstantine! Well deserved. -Bill On Wed, Feb 26, 2020 at 5:37 PM Jason Gustafson wrote: > The PMC for Apache Kafka has invited Konstantine Karantasis as a committer > and we > are pleased to announce that he has accepted! > > Konstantine has contributed 56 patches and helped

Re: access to jiira

2020-02-26 Thread Bill Bejeck
Hi Stepanenko, You've been added as a contributor to Jira, so you should be able to self-assign tickets now. Thanks for your interest in Apache Kafka. -Bill On Wed, Feb 26, 2020 at 4:14 AM we studio wrote: > Hello. I would like to contribute to Kafka. Could you please add me to > jira? My

[jira] [Resolved] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-19 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9533. Resolution: Fixed > ValueTransform forwards `null` val

Re: [VOTE] KIP-568: Explicit rebalance triggering on the Consumer

2020-02-11 Thread Bill Bejeck
Thanks for the KIP Sophie. It's a +1 (binding) for me. -Bill On Tue, Feb 11, 2020 at 4:21 PM Konstantine Karantasis < konstant...@confluent.io> wrote: > The KIP reads quite well for me now and I think this feature will enable > even more efficient load balancing for specific use cases. > > I'm

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

2020-02-11 Thread Bill Bejeck
Hi Sophie, Thanks for the KIP, makes sense to me. One quick question, I'm not sure if it's relevant or not. If a user provides a `ConsumerRebalanceListener` and a rebalance is triggered from an `enforceRebalance` call, it seems possible the listener won't get called since partition assignments

Re: [DISCUSS] 2.4.1 Bug Fix Release

2020-02-09 Thread Bill Bejeck
Hi Bill, > > Sounds good. +1. > > best, > Colin > > On Mon, Feb 3, 2020, at 17:27, Bill Bejeck wrote: > > Hi All, > > > > I'd like to volunteer for the release manager of the 2.4.1 bug fix > release. > > > > Kafka 2.4.0 was released on December

[jira] [Created] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

2020-02-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9530: -- Summary: Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout Key: KAFKA-9530 URL: https://issues.apache.org/jira/browse/KAFKA-9530

[DISCUSS] 2.4.1 Bug Fix Release

2020-02-03 Thread Bill Bejeck
Hi All, I'd like to volunteer for the release manager of the 2.4.1 bug fix release. Kafka 2.4.0 was released on December 16, 2019, and so far 19 issues have been fixed since then. Here is a complete list:

[jira] [Resolved] (KAFKA-9152) Improve Sensor Retrieval

2020-01-24 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9152. Resolution: Fixed > Improve Sensor Retrieval > - > >

[jira] [Resolved] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

2020-01-24 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7317. Resolution: Fixed > Use collections subscription for main consumer to reduce metad

[jira] [Resolved] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

2020-01-24 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8821. Resolution: Fixed Resolved via [https://github.com/apache/kafka/pull/7969] > Avoid patt

Re: Create KIP Permission

2020-01-23 Thread Bill Bejeck
Thomas, you're all set now. -Bill On Thu, Jan 23, 2020 at 10:17 AM Thomas Becker wrote: > I'd like permission to create a KIP please. My confluence account is > twbecker. > > > > > This email and any attachments may contain confidential and privileged >

Re: [VOTE] KIP-558: Add Connect REST API endpoints to view the topics used by connectors in Kafka Connect

2020-01-21 Thread Bill Bejeck
Thanks for the KIP Konstantine. This will be very useful for Connect. +1(binding) -Bill On Tue, Jan 21, 2020 at 2:12 PM Almog Gavra wrote: > Another thanks from me! +1 (non-binding) > > On Tue, Jan 21, 2020 at 11:04 AM Randall Hauch wrote: > > > Thanks again for the KIP and this improvement

Re: Create KIP permission.

2020-01-21 Thread Bill Bejeck
Done. Thanks for your interest in Apache Kafka. -Bill On Tue, Jan 21, 2020 at 11:35 AM Игорь Мартемьянов wrote: > Username: ledostuff > > вт, 21 янв. 2020 г., 15:43 Игорь Мартемьянов : > > > Hello there. > > I'd like to request permission to Kafka confluence page to be able to > > create

Re: [VOTE] KIP-216: IQ should throw different exceptions for different errors

2020-01-16 Thread Bill Bejeck
Thanks for the KIP. +1 (binding) -Bill On Tue, Jan 14, 2020 at 9:41 AM Navinder Brar wrote: > +1 (non-binding) With a small comment which was mentioned by Vinoth as > well. Did we fix on the flag for StreamsRebalancingException, I don't see > it in the KIP. > -Navinder > > > On Tuesday,

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

2020-01-16 Thread Bill Bejeck
>> experience" problem, and making it fatal would be more > > >> helpful. Even in a production context, there's no reason not > > >> to sequence your application startup such that you don't > > >> accept queries until after Streams is started. Thus, I guess >

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

2020-01-15 Thread Bill Bejeck
Thanks for KIP Vito. Overall the KIP LGTM, but I'd have to agree with others on merging the `StreamsNotRunningException` and `StateStoreNotAvailableException` classes. Since in both cases, the thread state is in `PENDING_SHUTDOWN || NOT_RUNNING || ERROR` I'm not even sure how we could

Re: [VOTE] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions

2020-01-15 Thread Bill Bejeck
Thanks for the KIP. +1 (binding) -Bill On Wed, Jan 15, 2020 at 3:45 PM M. Manna wrote: > +1 (non-binding) > > Thanks for this KIP > > Regards, > > On Wed, 15 Jan 2020 at 20:35, Mitchell wrote: > > > +1(non-binding) > > > > Very useful > > -mitch > > > > On Wed, Jan 15, 2020, 3:29 PM Anna

Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions

2020-01-15 Thread Bill Bejeck
ore, it might actually be better > > if we could _exclude_ `ClassCastException` as it may indicate a miss > > configured Serde? > > > > > > -Matthias > > > > On 1/14/20 4:15 PM, Bill Bejeck wrote: > > > Hi Anna, > > > > > > Thanks

Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions

2020-01-14 Thread Bill Bejeck
Hi Anna, Thanks for getting this KIP going again. I agree with pushing forward on option 0 as well. I a couple of questions about the KIP as written. The KIP states that any {{ClassCastException}} thrown plus any other unchecked exceptions will result in a log statement and not stop processing

Re: [VOTE] On the new KIP-158: Kafka Connect allows source connectors to set topic settings when creating new topics

2020-01-14 Thread Bill Bejeck
Thanks for the KIP, Konstantine. The KIP is very clear and it seems like it will have a very positive impact. +1(binding) -Bill On Tue, Jan 14, 2020 at 2:02 PM Tom Bentley wrote: > +1 (non-binding). Thanks for the KIP! > > On Tue, Jan 14, 2020 at 6:45 PM Randall Hauch wrote: > > > Thanks

Re: [ANNOUNCE] New Kafka PMC Members: Colin, Vahid and Manikumar

2020-01-14 Thread Bill Bejeck
Congrats Colin, Vahid and Manikumar! Well deserved. -Bill On Tue, Jan 14, 2020 at 12:30 PM Gwen Shapira wrote: > Hi everyone, > > I'm happy to announce that Colin McCabe, Vahid Hashemian and Manikumar > Reddy are now members of Apache Kafka PMC. > > Colin and Manikumar became committers on

[jira] [Created] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

2020-01-10 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9398: -- Summary: Kafka Streams main thread may not exit even after close timeout has passed Key: KAFKA-9398 URL: https://issues.apache.org/jira/browse/KAFKA-9398 Project: Kafka

[jira] [Created] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules

2019-12-12 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9294: -- Summary: Enhance DSL Naming Guide to Include All Naming Rules Key: KAFKA-9294 URL: https://issues.apache.org/jira/browse/KAFKA-9294 Project: Kafka Issue Type

[jira] [Created] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

2019-12-05 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9273: -- Summary: Refactor AbstractJoinIntegrationTest and Sub-classes Key: KAFKA-9273 URL: https://issues.apache.org/jira/browse/KAFKA-9273 Project: Kafka Issue Type

Re: Please help me add the permission for creating KIP,thanks

2019-11-26 Thread Bill Bejeck
You're all set now. Thanks for your interest in Apache Kafka. -Bill On Tue, Nov 26, 2019 at 11:28 AM 卢世吉 wrote: > I want to create KIP,but I don't have the permission,please help me solve > it,my username is stevenlumt > > > > >

[jira] [Resolved] (KAFKA-9086) Refactor Processor Node Streams Metrics

2019-11-19 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9086. Resolution: Fixed > Refactor Processor Node Streams Metr

Re: [VOTE] KIP-531: Drop support for Scala 2.11 in Kafka 2.5

2019-11-18 Thread Bill Bejeck
+1 (binding) On Mon, Nov 18, 2019 at 9:30 AM Satish Duggana wrote: > +1 (non-binding), Thanks Ismael for the KIP. I believe it is time to > drop Scala 2.11. > > > On Mon, Nov 18, 2019 at 7:10 PM Ivan Yurchenko > wrote: > > > > Do I understand correctly, that non-commiters can also vote,

Re: [VOTE] KIP-535: Allow state stores to serve stale reads during rebalance

2019-11-15 Thread Bill Bejeck
+1 (binding) On Fri, Nov 15, 2019 at 1:11 AM Matthias J. Sax wrote: > +1 (binding) > > > On 11/14/19 3:48 PM, Guozhang Wang wrote: > > +1 (binding), thanks for the KIP! > > > > Guozhang > > > > On Fri, Nov 15, 2019 at 4:38 AM Navinder Brar > > wrote: > > > >> Hello all, > >> > >> I'd like to

[jira] [Created] (KAFKA-9188) Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

2019-11-14 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9188: -- Summary: Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9188 URL: https://issues.apache.org/jira/browse/KAFKA-9188

[jira] [Created] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-11-14 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9187: -- Summary: kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9187 URL: https://issues.apache.org/jira/browse/KAFKA-9187

[jira] [Created] (KAFKA-9182) Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled

2019-11-13 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9182: -- Summary: Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled Key: KAFKA-9182

[jira] [Created] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

2019-11-13 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9181: -- Summary: Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-9181 URL: https://issues.apache.org/jira/browse/KAFKA-9181

[jira] [Resolved] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

2019-11-13 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9072. Resolution: Fixed > Add Section to Streams Developer Guide for Topology Naming (KIP-

Re: [ANNOUNCE] New committer: John Roesler

2019-11-12 Thread Bill Bejeck
Congratulations John! On Tue, Nov 12, 2019 at 6:20 PM Matthias J. Sax wrote: > Congrats John! > > > On 11/12/19 2:52 PM, Boyang Chen wrote: > > Great work John! Well deserved > > > > On Tue, Nov 12, 2019 at 1:56 PM Guozhang Wang > wrote: > > > >> Hi Everyone, > >> > >> The PMC of Apache Kafka

[jira] [Reopened] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

2019-11-12 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-9011: There's still something left to address on this PR [https://github.com/apache/kafka/pull/7520

Re: Why standby tasks read from the StandbyTasks::checkpointedOffsets in assignStandbyPartitions()

2019-11-12 Thread Bill Bejeck
This could be a significant performance issue for some, so I think this fix needs to go into 2.4. Just my 2 cents. -Bill On Mon, Nov 11, 2019 at 5:57 PM John Roesler wrote: > Ok, created: https://github.com/apache/kafka/pull/7681 > > I'm on the fence about whether we should file this as a

Re: Subject: [VOTE] 2.2.2 RC2

2019-11-08 Thread Bill Bejeck
- verified signatures - built it from source - ran unit tests +1 (non-binding) Thanks for running the release, Randall! -Bill On Fri, Nov 8, 2019 at 4:40 PM David Arthur wrote: > * Glanced through docs, release notes > * Downloaded RC2 binaries, verified signatures > * Ran through

Re: [DISCUSS] KIP-531: Drop support for Scala 2.11 in Kafka 2.5

2019-11-08 Thread Bill Bejeck
Thanks for the KIP Ismael. +1 for me. -Bill On Fri, Nov 8, 2019 at 11:52 AM Ismael Juma wrote: > I was hoping we'd get the documentation update in the 2.4 release notes so > that it's not a surprise for 2.5 users. > > Ismael > > On Fri, Nov 8, 2019 at 8:40 AM Jose Armando Garcia Sancio < >

Re: [VOTE] KIP-544: Make metrics exposed via JMX configurable

2019-11-08 Thread Bill Bejeck
Thanks for the KIP, +1 (binding). -Bill On Fri, Nov 8, 2019 at 1:28 PM Gwen Shapira wrote: > +1 (binding) > > On Thu, Nov 7, 2019 at 11:17 AM Xavier Léauté wrote: > > > > Hi everyone, > > > > I'd like to open up the vote for KIP-544 on making exposed JMX metrics > more > > configurable. > > >

Re: [ANNOUNCE] New committer: Mickael Maison

2019-11-07 Thread Bill Bejeck
Congratulations Mickael! Well deserved! -Bill On Thu, Nov 7, 2019 at 4:38 PM Jun Rao wrote: > Hi, Everyone, > > The PMC of Apache Kafka is pleased to announce a new Kafka committer > Mickael > Maison. > > Mickael has been contributing to Kafka since 2016. He proposed and > implemented multiple

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

2019-11-06 Thread Bill Bejeck
Thanks for the KIP. +1 (binding) -Bill On Wed, Nov 6, 2019 at 1:22 AM Matthias J. Sax wrote: > +1 (binding) > > > On 10/31/19 10:52 AM, Walker Carlson wrote: > > Hello all, > > > > I'd like to call a vote on the updated KIP-150: Kafka-Streams Cogroup > > found here > > < >

[jira] [Resolved] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-30 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8980. Resolution: Fixed > Refactor State-Store-level Metr

[jira] [Resolved] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

2019-10-29 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9077. Resolution: Fixed > System Test Failure: StreamsSimpleBenchmarkT

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

2019-10-28 Thread Bill Bejeck
Hi Walker, Thanks for taking on KIP-150, the co-group will be very useful. Regarding the naming, IMHO, we should stick to the current pattern, and that is, we provide overloads with a "Named" operator for the "aggregate" methods (I believe those are the only ones that create a processor).

[jira] [Resolved] (KAFKA-8968) Refactor Task-level Metrics

2019-10-25 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8968. Resolution: Fixed > Refactor Task-level Metr

Re: [DISCUSS] KIP-535: Allow state stores to serve stale reads during rebalance

2019-10-25 Thread Bill Bejeck
I am jumping in a little late here. Overall I agree with the proposal to push decision making on what/how to query in the query layer. For point 5 from above, I'm slightly in favor of having a new method, "standbyMetadataForKey()" or something similar. Because even if we return all tasks in one

[jira] [Created] (KAFKA-9098) Name Repartition Filter, Source, and Sink Processors

2019-10-24 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9098: -- Summary: Name Repartition Filter, Source, and Sink Processors Key: KAFKA-9098 URL: https://issues.apache.org/jira/browse/KAFKA-9098 Project: Kafka Issue Type

Re: [VOTE] KIP-523 Add KStream#toTable to the Streams DSL

2019-10-24 Thread Bill Bejeck
Thanks for the KIP, this is something that will be appreciated by the community. +1(binding) -Bill On Thu, Oct 24, 2019 at 12:54 PM Matthias J. Sax wrote: > Thanks for the KIP! > > +1 (binding) > > > -Matthias > > On 10/24/19 6:19 AM, aishwarya kumar wrote: > > Hello All, > > > > After

Re: [VOTE] KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

2019-10-24 Thread Bill Bejeck
Hi Rabi, Thanks for the KIP. Just to be clear, we're going to deprecate `UsePreviousTimeOnInvalidTimeStamp` and add `UsePartitionOnInvalidTimeStamp` class correct? Otherwise, it's a +1 (binding) from me. -Bill On Thu, Oct 24, 2019 at 8:09 AM Bruno Cadonna wrote: > Hi Rabi, > > Thank you for

[jira] [Created] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

2019-10-21 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9072: -- Summary: Add Section to Streams Developer Guide for Topology Naming (KIP-307) Key: KAFKA-9072 URL: https://issues.apache.org/jira/browse/KAFKA-9072 Project: Kafka

Re: [DISCUSS] KIP-539: Implement mechanism to flush out records in low volume suppression buffers

2019-10-18 Thread Bill Bejeck
Hi Richard, Thanks for the KIP proposal. I understand the situation you are describing. But in my mind, if there is a low traffic condition and you need to keep records going downstream at regular intervals, I'm wondering if using suppression is the correct approach. IMHO it seems it would be

[jira] [Resolved] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

2019-10-17 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9053. Resolution: Fixed > AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERS

[jira] [Created] (KAFKA-9019) Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

2019-10-10 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9019: -- Summary: Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig Key: KAFKA-9019 URL: https://issues.apache.org/jira/browse/KAFKA-9019

[jira] [Created] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

2019-10-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9009: -- Summary: Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete Key: KAFKA-9009 URL: https://issues.apache.org/jira/browse/KAFKA-9009

[jira] [Created] (KAFKA-9008) Flaky Test kafka.api.SaslSslAdminClientIntegrationTest.testDescribeConfigsForTopic

2019-10-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9008: -- Summary: Flaky Test kafka.api.SaslSslAdminClientIntegrationTest.testDescribeConfigsForTopic Key: KAFKA-9008 URL: https://issues.apache.org/jira/browse/KAFKA-9008 Project

[jira] [Created] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

2019-10-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9007: -- Summary: Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover Key: KAFKA-9007 URL: https://issues.apache.org/jira/browse/KAFKA-9007 Project: Kafka

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-10-09 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8460: Test failed again in  [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/25644/testReport/junit

[jira] [Created] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-09 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9006: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9006 URL: https://issues.apache.org/jira/browse/KAFKA-9006

[jira] [Resolved] (KAFKA-8944) Compiler Warning

2019-10-08 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8944. Resolution: Fixed > Compiler Warning > > > Key

[jira] [Created] (KAFKA-9002) org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

2019-10-08 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9002: -- Summary: org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated Key: KAFKA-9002 URL: https://issues.apache.org/jira/browse/KAFKA-9002

Re: [VOTE] KIP-527: Add VoidSerde to Serdes

2019-10-07 Thread Bill Bejeck
Thanks for the KIP. +1(binding) -Bill On Mon, Oct 7, 2019 at 5:57 PM Matthias J. Sax wrote: > +1 (binding) > > > -Matthias > > On 10/6/19 8:02 PM, Nikolay Izhikov wrote: > > Hello, > > > > Any additional feedback on this? > > Do we need this in Kafka? > > > > В Ср, 02/10/2019 в 08:30 +0200,

Re: A New Contributor

2019-10-07 Thread Bill Bejeck
Hi Ersin, Thanks for your interest in Apache Kafka. You're all set now. -Bill On Mon, Oct 7, 2019 at 10:44 AM Ersin Bayraktar wrote: > Hello Kafka devs, > > I would like to contribute to Kafka Core, Kafka-Streams and documentation. > For this purpose, I would like to be added to the

[jira] [Resolved] (KAFKA-3705) Support non-key joining in KTable

2019-10-03 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-3705. Resolution: Fixed > Support non-key joining in KTa

Re: Granting permissions for Create KIP

2019-10-01 Thread Bill Bejeck
Rabi, You're all set now. Thanks for the interest in Apache Kafka. -Bill On Tue, Oct 1, 2019 at 6:49 AM RABI K.C. wrote: > Hello, > > I am new to kafka and have to create KIP for KAFKA-8953 and was going > through > >

[jira] [Reopened] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

2019-09-28 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8807: Reopening this as I am going to refactor the test to check that close is only called once during

Re: Please Add Jira and Git Users

2019-09-26 Thread Bill Bejeck
Hi David, First, you'll need to set up an account with Jira, then share you Jira user-id on the list here and we can add you to the contributors list. You'll also want to read https://kafka.apache.org/contributing. Thanks for your interest in Apache Kafka. -Bill On Thu, Sep 26, 2019 at 5:42

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

2019-09-24 Thread Bill Bejeck
ing). > > Thanks for tackling this, Bill. > -John > > On Thu, Sep 19, 2019 at 3:09 PM Guozhang Wang wrote: > > > > Thanks Bill for the update, I'm +1 as well (binding). > > > > On Thu, Sep 19, 2019 at 11:25 AM Bill Bejeck wrote: > > > > > Thanks for

[jira] [Resolved] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

2019-09-24 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6958. Resolution: Fixed Thanks again [~fhussonnois] for your hard work and persistence in seeing

[jira] [Resolved] (KAFKA-8859) Refactor Cache-level Streams Metrics

2019-09-23 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8859. Resolution: Fixed > Refactor Cache-level Streams Metr

Re: [VOTE] KIP-521: Redirect Connect log4j messages also to a file by default

2019-09-20 Thread Bill Bejeck
Nice job on the KIP Konstantine. This is a great improvement. +1 (binding) -Bill On Fri, Sep 20, 2019 at 5:07 PM Mitchell wrote: > +1 (non-binding). > > Love this change. > > On Fri, Sep 20, 2019, 4:37 PM Randall Hauch wrote: > > > +1 (binding) > > > > Great work, Konstantine. > > > > On

Re: [VOTE] KIP-517: Add consumer metrics to observe user poll behavior

2019-09-20 Thread Bill Bejeck
+1 (binding) Thanks for the KIP! -Bill On Fri, Sep 20, 2019 at 1:28 PM Jason Gustafson wrote: > +1 Thanks! > > On Thu, Sep 19, 2019 at 11:22 PM Tom Bentley wrote: > > > +1 (non-binding). > > > > On Fri, Sep 20, 2019 at 7:00 AM Maulin Vasavada < > maulin.vasav...@gmail.com > > > > > wrote: >

Re: [DISCUSS] KIP-517: Add consumer metric indicating time between poll calls

2019-09-20 Thread Bill Bejeck
Hi Kevin, I'm coming in a little late, but thanks for the KIP, this will be very useful. It's a +1 for me. -Bill On Fri, Sep 20, 2019 at 11:32 AM Kevin Lu wrote: > Hi Jason, > > That is a good point in making the ratio metric consistent with the broker > idle metrics. I have updated the KIP

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

2019-09-20 Thread Bill Bejeck
Thanks for the KIP! +1(binding) -Bill On Fri, Sep 20, 2019 at 10:06 AM Guozhang Wang wrote: > +1 (binding), Thanks! > > On Fri, Sep 20, 2019 at 9:56 AM Matthias J. Sax > wrote: > > > Thanks for the KIP Jukka! > > > > +1 (binding) > > > > -Matthias > > > > On 9/20/19 9:44 AM, Paul Whalen

Re: [VOTE] KIP-528: Deprecate PartitionGrouper configuration and interface

2019-09-19 Thread Bill Bejeck
Thanks for the KIP Matthias. I agree with Guozhang on this one. +1 (binding) -Bill On Thu, Sep 19, 2019 at 4:41 PM Guozhang Wang wrote: > +1, we should do that long ago :) > > Guozhang > > On Thu, Sep 19, 2019 at 4:28 PM Matthias J. Sax > wrote: > > > Hi, > > > > I would like to propose a

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

2019-09-19 Thread Bill Bejeck
t; On 9/19/19 9:40 AM, John Roesler wrote: > > I'm +1 either way :) > > -John > > > > On Wed, Sep 18, 2019 at 5:37 PM Bill Bejeck wrote: > >> > >> Good catch! I meant to propose the name to be "StreamJoin". I have > updated > >> the

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

2019-09-18 Thread Bill Bejeck
t; but the > class name defined is StreamJoin.Which one did you propose? Personally I > think StreamJoined with better aligned with other control objects, but if > you think otherwise is better I can be convinced too :) > > > Guozhang > > On Wed, Sep 18, 2019 at 4

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

2019-09-18 Thread Bill Bejeck
All, since we have updated KIP-479 https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+StreamJoin+config+object+to+Join and seem to have completed the discussion for the updates, I'd like to call for everyone to vote again. Thanks, Bill On Fri, Aug 2, 2019 at 10:46 AM Bill Bejeck

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

2019-09-18 Thread Bill Bejeck
gt; > > > > -Matthias > > > > > > On 9/17/19 4:52 PM, aishwarya kumar wrote: > > > Hi Bill, > > > > > > Thanks for clarifying, and the KIP looks great!! > > > > > > Best regards, > > > Aishwarya > > > > > >

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

2019-09-17 Thread Bill Bejeck
n to use different WindowStores would be to enable in-memory joins. > Best, > Aishwarya > Regards, Bill > > On Tue, Sep 17, 2019 at 4:05 PM Bill Bejeck wrote: > > > Guozhang, > > > > Thanks for the comments. > > > > Yes, you are correct in you

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

2019-09-17 Thread Bill Bejeck
Just to clarify I'll update `as(StoreSupplier, StoreSupplier)` to `with(..., ...)` and change the class name from `StreamJoined` to `StreamJoin` -Bill On Tue, Sep 17, 2019 at 2:09 PM Bill Bejeck wrote: > Thanks for the comments, Matthias. > > I like both suggestions regarding

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

2019-09-17 Thread Bill Bejeck
-supplier, she is forced to also provide a name via the > > store-supplier. So there's no way to say "I want to provide my own store > > engine but let the library decide its name", is that right? > > > > > > Guozhang > > > > > > On

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