[jira] [Assigned] (KAFKA-4662) Improve test coverage TopologyBuilder

[ https://issues.apache.org/jira/browse/KAFKA-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4662: -- Assignee: Bill Bejeck > Improve test coverage TopologyBuil

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824683#comment-15824683 ] Bill Bejeck commented on KAFKA-4468: Hi, Eno - I was, but for a couple of reasons I unassigned myself

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822833#comment-15822833 ] Bill Bejeck commented on KAFKA-4125: [~mjsax] - Sounds reasonable to me. With the information you

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815003#comment-15815003 ] Bill Bejeck commented on KAFKA-4125: [~guozhang] [~mjsax] Thanks for the response. Sure I'll give

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812586#comment-15812586 ] Bill Bejeck commented on KAFKA-4125: Is this task still viable/desired? If so I'll pick it up

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

e previously voted? > >> > >> Thank you > >> no > >> > >>> On 6 Jan 2017, at 17:31, Sriram Subramanian <r...@confluent.io> wrote: > >>> > >>> +1 > >>> > >>> On Fri, Jan 6, 2017 at 9:12 AM,

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

+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 (binding). > > > >

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

+1 On Fri, Jan 6, 2017 at 5:57 AM, Damian Guy wrote: > +1 > > On Fri, 6 Jan 2017 at 09:37 Eno Thereska wrote: > > > The discussion points for KIP-104 are addressed. At this point we'd like > > to start the vote for it: > > > > > >

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802932#comment-15802932 ] Bill Bejeck commented on KAFKA-4601: Thanks for the explanation. Avoiding duplicated partitioning

[jira] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4601: --- Assignee: (was: Bill Bejeck) > Avoid duplicated repartitioning in KStream

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802878#comment-15802878 ] Bill Bejeck commented on KAFKA-4601: If it's ok, picking this one up. > Avoid duplica

[jira] [Assigned] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4601: -- Assignee: Bill Bejeck > Avoid duplicated repartitioning in KStream

[jira] [Work stopped] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4468 stopped by Bill Bejeck. -- > Correctly calculate the window end timestamp after read from state sto

[jira] [Updated] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4468: --- Assignee: (was: Bill Bejeck) > Correctly calculate the window end timestamp after read from st

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15783884#comment-15783884 ] Bill Bejeck commented on KAFKA-4468: Yes, that makes sense. I misinterpreted the requirements

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

+1 On Mon, Dec 12, 2016 at 12:29 PM, Matthias J. Sax wrote: > +1 > > On 12/12/16 3:45 AM, Damian Guy wrote: > > Hi all, > > > > I'd like to start the vote for KIP-99: > > https://cwiki.apache.org/confluence/pages/viewpage. > action?pageId=67633649 > > > > There is a PR

Re: [VOTE] KIP-100 - Relax Type constraints in Kafka Streams API

+1 On Mon, Dec 12, 2016 at 3:44 AM, Damian Guy wrote: > +1 > > On Sun, 11 Dec 2016 at 08:07 Ewen Cheslack-Postava > wrote: > > > +1 (binding) > > > > My only concern was around compatibility. It seems like the one case it > is > > incompatible would be,

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730787#comment-15730787 ] Bill Bejeck commented on KAFKA-4468: Unless I'm missing something, this task implies we'll need

[jira] [Work started] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4468 started by Bill Bejeck. -- > Correctly calculate the window end timestamp after read from state sto

Re: [VOTE] KIP-94: Session Windows

+1 On Tue, Dec 6, 2016 at 4:55 PM, Guozhang Wang wrote: > +1 (binding) > > On Tue, Dec 6, 2016 at 9:07 AM, Matthias J. Sax > wrote: > > > +1 > > > > On 12/6/16 7:40 AM, Eno Thereska wrote: > > > +1 (non-binding) > > > > > > Thanks > > > Eno > > >> On

Re: [VOTE] KIP-96 - Add per partition metrics for in-sync and replica count

+1 On Mon, Dec 5, 2016 at 8:07 AM, Ismael Juma wrote: > Thanks for the KIP, +1 (binding). > > Ismael > > On Thu, Dec 1, 2016 at 12:59 PM, Tom Crayford > wrote: > > > +1 (non-binding) > > > > On Thu, Dec 1, 2016 at 12:11 AM, Apurva Mehta

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15707119#comment-15707119 ] Bill Bejeck commented on KAFKA-4468: Picking this one up. > Correctly calculate the window

[jira] [Assigned] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4468: -- Assignee: Bill Bejeck > Correctly calculate the window end timestamp after read from st

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

+1 (non-binding) Thanks, Bill On Tue, Nov 29, 2016 at 1:34 PM, Matthias J. Sax wrote: > I’d like to start the voting process for KIP-93: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 93%3A+Improve+invalid+timestamp+handling+in+Kafka+Streams > > -Matthias

[jira] [Updated] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4312: --- Component/s: streams > void KTableImpl.writeAsText(String filePath) throws NullPointerException w

[jira] [Updated] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4312: --- Fix Version/s: 0.10.1.1 Status: Patch Available (was: In Progress) > v

[jira] [Work started] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4312 started by Bill Bejeck. -- > void KTableImpl.writeAsText(String filePath) throws NullPointerException w

[jira] [Assigned] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4312: -- Assignee: Bill Bejeck > void KTableImpl.writeAsText(String filePath) thr

[jira] [Updated] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4114: --- Status: Patch Available (was: In Progress) > Allow for different "auto.offset.reset&quo

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564050#comment-15564050 ] Bill Bejeck commented on KAFKA-4114: Fair enough doing so now. > Allow for differ

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15563934#comment-15563934 ] Bill Bejeck commented on KAFKA-4114: I have a working solution, just waiting for resolution to KAFKA

[jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4269: --- Fix Version/s: 0.10.1.0 Status: Patch Available (was: In Progress) > Multiple KStr

[jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4269: --- Description: I discovered this issue while doing testing for for KAFKA-4114. KAFKA-4131 fixed

[jira] [Work started] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4269 started by Bill Bejeck. -- > Multiple KStream instances with at least one Regex source causes NPE when >

[jira] [Assigned] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4269: -- Assignee: Bill Bejeck (was: Guozhang Wang) > Multiple KStream instances with at least

[jira] [Created] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

Bill Bejeck created KAFKA-4269: -- Summary: Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers Key: KAFKA-4269 URL: https://issues.apache.org/jira/browse/KAFKA-4269

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531675#comment-15531675 ] Bill Bejeck commented on KAFKA-4114: No worries on the response. Thanks for clearing things up. I

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513498#comment-15513498 ] Bill Bejeck commented on KAFKA-4114: Hi Matthias, I've started working on this and wanted

Re: [VOTE] KIP-54: Sticky Partition Assignment Strategy

+1 On Thu, Sep 15, 2016 at 5:16 AM, Rajini Sivaram < rajinisiva...@googlemail.com> wrote: > +1 (non-binding) > > On Wed, Sep 14, 2016 at 12:37 AM, Jason Gustafson > wrote: > > > Thanks for the KIP. +1 from me. > > > > On Tue, Sep 13, 2016 at 12:05 PM, Vahid S Hashemian < > >

[jira] [Work started] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4114 started by Bill Bejeck. -- > Allow for different "auto.offset.reset" strategies for different

Re: [VOTE] KIP-79 - ListOffsetRequest v1 and search by timestamp methods in new consumer.

+1 On Tue, Sep 13, 2016 at 11:08 PM, Jason Gustafson wrote: > +1 and thanks for the great proposal! > > On Fri, Sep 9, 2016 at 4:38 PM, Becket Qin wrote: > > > Hi all, > > > > I'd like to start the voting for KIP-79 > > > > In short we propose to : > >

[jira] [Updated] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4131: --- Status: Patch Available (was: In Progress) Working on getting an integration test for this bug fix

[jira] [Work started] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4131 started by Bill Bejeck. -- > Multiple Regex KStream-Consumers cause Null pointer exception in > addRawR

[jira] [Commented] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467695#comment-15467695 ] Bill Bejeck commented on KAFKA-4131: If it's ok, I'll pick this one up > Multiple Regex KStr

[jira] [Assigned] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4131: -- Assignee: Bill Bejeck (was: Guozhang Wang) > Multiple Regex KStream-Consumers cause N

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15458985#comment-15458985 ] Bill Bejeck commented on KAFKA-3478: Makes sense, but I didn't realize that was the case, thanks

[jira] [Assigned] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4114: -- Assignee: Bill Bejeck (was: Guozhang Wang) > Allow for different "auto.offs

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15458306#comment-15458306 ] Bill Bejeck commented on KAFKA-3478: [~mjsax] thanks for the heads up, but it looks like

[jira] [Updated] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4023: --- Status: Patch Available (was: In Progress) > Add thread id as prefix in Kafka Streams thread logg

Re: [VOTE] KIP-77: Improve Kafka Streams Join Semantics

+1 On Mon, Aug 29, 2016 at 5:50 AM, Matthias J. Sax wrote: > I’d like to initiate the voting process for KIP-77: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 77%3A+Improve+Kafka+Streams+Join+Semantics > > -Matthias > > >

Re: [DISCUSS] KIP-76: Improve Kafka Streams Join Semantics

+1 On Fri, Aug 26, 2016 at 8:12 AM, Matthias J. Sax wrote: > If there is no further feedback, I would like to start the voting process. > > -Matthias > > On 08/19/2016 12:18 PM, Matthias J. Sax wrote: > > Hi, > > > > we have created KIP-76: Improve Kafka Streams Join

Re: [VOTE] KIP-63: Unify store and downstream caching in streams

+1 On Thu, Aug 25, 2016 at 11:45 AM, Matthias J. Sax wrote: > +1 > > On 08/25/2016 04:22 PM, Damian Guy wrote: > > +1 > > > > On Thu, 25 Aug 2016 at 11:57 Eno Thereska > wrote: > > > >> Hi folks, > >> > >> We'd like to start the vote for KIP-63.

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429559#comment-15429559 ] Bill Bejeck commented on KAFKA-3478: [~mjsax], thanks for the clarification. I'll take a look at what

[jira] [Work started] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4023 started by Bill Bejeck. -- > Add thread id as prefix in Kafka Streams thread logg

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15422907#comment-15422907 ] Bill Bejeck commented on KAFKA-3478: Is this task still available and is it a feature that is still

[jira] [Commented] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15422890#comment-15422890 ] Bill Bejeck commented on KAFKA-4023: Picking this one up. Just let me know if someone is currently

[jira] [Assigned] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4023: -- Assignee: Bill Bejeck > Add thread id as prefix in Kafka Streams thread logg

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420061#comment-15420061 ] Bill Bejeck commented on KAFKA-3973: Attaching JMH benchmark results, removing the previous hand

[jira] [Commented] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15412231#comment-15412231 ] Bill Bejeck commented on KAFKA-3989: [~ijuma] After your comment, I tried to implement the jmh-gradle

[jira] [Updated] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3989: --- Status: Patch Available (was: In Progress) > Add JMH module for Benchma

[jira] [Comment Edited] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15411821#comment-15411821 ] Bill Bejeck edited comment on KAFKA-3973 at 8/8/16 4:55 PM: I used JMH

[jira] [Comment Edited] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15411821#comment-15411821 ] Bill Bejeck edited comment on KAFKA-3973 at 8/8/16 4:45 PM: I used JMH

[jira] [Comment Edited] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15411821#comment-15411821 ] Bill Bejeck edited comment on KAFKA-3973 at 8/8/16 3:34 PM: I used JMH

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15411821#comment-15411821 ] Bill Bejeck commented on KAFKA-3973: I used JMH to benchmark the performance of caching bytes vs

[jira] [Commented] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408276#comment-15408276 ] Bill Bejeck commented on KAFKA-3989: Yes, the classpath entry is in the 'buildscript section. To me

[jira] [Updated] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3989: --- Fix Version/s: 0.10.1.0 > Add JMH module for Benchma

[jira] [Comment Edited] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15407054#comment-15407054 ] Bill Bejeck edited comment on KAFKA-3989 at 8/4/16 3:03 AM: I opted to try

[jira] [Commented] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15407054#comment-15407054 ] Bill Bejeck commented on KAFKA-3989: I opted to try the gradle shadow plugin first (https

[jira] [Comment Edited] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15407054#comment-15407054 ] Bill Bejeck edited comment on KAFKA-3989 at 8/4/16 3:03 AM: I opted to try

[jira] [Work started] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3989 started by Bill Bejeck. -- > Add JMH module for Benchma

[jira] [Updated] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3973: --- Status: Patch Available (was: In Progress) > Investigate feasibility of caching bytes vs. reco

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394761#comment-15394761 ] Bill Bejeck commented on KAFKA-3973: [~ijuma] I re-ran the tests with no instrumentation using

[jira] [Updated] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3989: --- Description: JMH is a Java harness for building, running, and analyzing benchmarks written in Java

[jira] [Created] (KAFKA-3989) Add JMH module for Benchmarks

Bill Bejeck created KAFKA-3989: -- Summary: Add JMH module for Benchmarks Key: KAFKA-3989 URL: https://issues.apache.org/jira/browse/KAFKA-3989 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393079#comment-15393079 ] Bill Bejeck commented on KAFKA-3973: [~enothereska] Will do, just need to finish up a few details

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391766#comment-15391766 ] Bill Bejeck commented on KAFKA-3973: Yes I ran the tests using instrumentation (-javaagent:), sorry I

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391229#comment-15391229 ] Bill Bejeck commented on KAFKA-3973: The results for the LRU investigation are below. There were three

[jira] [Updated] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3973: --- Attachment: MemoryLRUCache.java CachingPerformanceBenchmarks.java Benchmark test

[jira] [Work started] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3973 started by Bill Bejeck. -- > Investigate feasibility of caching bytes vs. reco

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374085#comment-15374085 ] Bill Bejeck commented on KAFKA-3101: [~enothereska] [~guozhang] With regards to the performance

[jira] [Comment Edited] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15369257#comment-15369257 ] Bill Bejeck edited comment on KAFKA-3101 at 7/9/16 7:26 PM: [~enothereska

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15369257#comment-15369257 ] Bill Bejeck commented on KAFKA-3101: [~enothereska] none actually, a misunderstanding on my part

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367923#comment-15367923 ] Bill Bejeck commented on KAFKA-3101: [~guozhang] [~enothereska] Would adding flatbuffers (https

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366591#comment-15366591 ] Bill Bejeck commented on KAFKA-3101: [~guozhang] ok will do. > Optimize Aggregation Outp

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366148#comment-15366148 ] Bill Bejeck commented on KAFKA-3101: [~enothereska] ok I get it now, KAFKA-3101 is being replaced

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15364919#comment-15364919 ] Bill Bejeck commented on KAFKA-3101: Is this available now? If so I'd like to pick this up if possible

[jira] [Work started] (KAFKA-3926) Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3926 started by Bill Bejeck. -- > Transient failu

[jira] [Commented] (KAFKA-3926) Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15363724#comment-15363724 ] Bill Bejeck commented on KAFKA-3926: Looking at this a bit more. The test in question is failing

[jira] [Commented] (KAFKA-3926) Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15360768#comment-15360768 ] Bill Bejeck commented on KAFKA-3926: I'll pick this up. > Transient failu

[jira] [Assigned] (KAFKA-3926) Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3926: -- Assignee: Bill Bejeck > Transient failu

[jira] [Commented] (KAFKA-3794) Add Stream / Table prefix in print functions

[ https://issues.apache.org/jira/browse/KAFKA-3794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356319#comment-15356319 ] Bill Bejeck commented on KAFKA-3794: [~guozhang] I was thinking of adding the parent processor node

[jira] [Created] (KAFKA-3903) Convert tests to use static helper methods for Consumer/Producer/StreamsConfigs setup

Bill Bejeck created KAFKA-3903: -- Summary: Convert tests to use static helper methods for Consumer/Producer/StreamsConfigs setup Key: KAFKA-3903 URL: https://issues.apache.org/jira/browse/KAFKA-3903

[jira] [Work started] (KAFKA-3794) Add Stream / Table prefix in print functions

[ https://issues.apache.org/jira/browse/KAFKA-3794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3794 started by Bill Bejeck. -- > Add Stream / Table prefix in print functi

Re: [jira] [Commented] (KAFKA-3482) [DOC] - Remove the part about LinkedIn running ZK 3.3.X

Please disregard - transposed digits on entering the pull request. On Mon, Jun 20, 2016 at 10:53 PM, ASF GitHub Bot (JIRA) wrote: > > [ >

[jira] [Updated] (KAFKA-3842) Add Helper Functions Into TestUtils

[ https://issues.apache.org/jira/browse/KAFKA-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3842: --- Fix Version/s: (was: 0.10.0.1) 0.10.1.0 Affects Version/s

[jira] [Work started] (KAFKA-3842) Add Helper Functions Into TestUtils

[ https://issues.apache.org/jira/browse/KAFKA-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3842 started by Bill Bejeck. -- > Add Helper Functions Into TestUt

Re: [DISCUSS] Java 8 as a minimum requirement

+1 for lambda expressions On Thu, Jun 16, 2016 at 5:13 PM, Grant Henke wrote: > I definitely think its time, but I am not sure if 0.10.1.0 is the release > version to drop support in. > > Would it make sense to drop Java 1.7 and Scala 2.10 support in Kafka 0.11 > to

[jira] [Updated] (KAFKA-3842) Add Helper Functions Into TestUtils

[ https://issues.apache.org/jira/browse/KAFKA-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3842: --- Description: Per guidance from [~guozhang] from PR #1477 move helper functions from

[jira] [Updated] (KAFKA-3842) Add Helper Functions Into TestUtils

[ https://issues.apache.org/jira/browse/KAFKA-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3842: --- Description: Per guidance from [~guozhang] from PR #1477 move helper functions from

[jira] [Created] (KAFKA-3842) Add Helper Functions Into TestUtils

Bill Bejeck created KAFKA-3842: -- Summary: Add Helper Functions Into TestUtils Key: KAFKA-3842 URL: https://issues.apache.org/jira/browse/KAFKA-3842 Project: Kafka Issue Type: Improvement

<    4   5   6   7   8   9   10   >