[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 duplicated

[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 DSL >

[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 stores >

[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 state

[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 and

[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 to

[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 stores >

[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 end

[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 state

[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 when

[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) > void

[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 when >

[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) throws

[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" strategies for

[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 different

[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

[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 KStream

[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 the

[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 > using

[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 one

[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 to

[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 input streams >

[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 > addRawRecords

[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

[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 Null

[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.offset.reset"

[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 they are

[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 logging

[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 logging >

[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 in

[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 logging >

[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

[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

[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 Benchmarks >

[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 to

[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 to

[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 to

[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 Benchmarks > - > >

[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 the

[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

[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 the

[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 Benchmarks > - > >

[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. records >

[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 the

[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 or

[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 and

[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. records >

[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

[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 Outputs >

[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

[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

[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 failures in >

[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 on

[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 failures in >

[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 failures in >

[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 functions >

[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 TestUtils > --- > >

[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

[jira] [Assigned] (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 ] Bill Bejeck reassigned KAFKA-3794: -- Assignee: Bill Bejeck > Add Stream / Table prefix in print functions >

[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=15317475#comment-15317475 ] Bill Bejeck commented on KAFKA-3794: picking this one up, mea culpa > Add Stream / Table prefix in

[jira] [Updated] (KAFKA-3443) Support regex topics in addSource() and stream()

[ https://issues.apache.org/jira/browse/KAFKA-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3443: --- Status: Patch Available (was: Open) Initial pass completed, ready for review > Support regex topics

[jira] [Work stopped] (KAFKA-3443) Support regex topics in addSource() and stream()

[ https://issues.apache.org/jira/browse/KAFKA-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3443 stopped by Bill Bejeck. -- > Support regex topics in addSource() and stream() >

[jira] [Commented] (KAFKA-3443) Support regex topics in addSource() and stream()

[ https://issues.apache.org/jira/browse/KAFKA-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15287764#comment-15287764 ] Bill Bejeck commented on KAFKA-3443: Status update - still actively working on this and I'm really

[jira] [Assigned] (KAFKA-3443) Support regex topics in addSource() and stream()

[ https://issues.apache.org/jira/browse/KAFKA-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3443: -- Assignee: Bill Bejeck > Support regex topics in addSource() and stream() >

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

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3101: -- Assignee: (was: Bill Bejeck) > Optimize Aggregation Outputs >

[jira] [Work stopped] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3101 stopped by Bill Bejeck. -- > Optimize Aggregation Outputs > > >

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

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

[jira] [Work started] (KAFKA-3101) Optimize Aggregation Outputs

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

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

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3101: -- Assignee: (was: Bill Bejeck) > Optimize Aggregation Outputs >

[jira] [Work stopped] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3101 stopped by Bill Bejeck. -- > Optimize Aggregation Outputs > > >

[jira] [Work started] (KAFKA-3101) Optimize Aggregation Outputs

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

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

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

[jira] [Updated] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

[ https://issues.apache.org/jira/browse/KAFKA-3430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3430: --- Status: Patch Available (was: Open) Submitted PR for KAFKA-3430 Allow users to set key in

[jira] [Work stopped] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

[ https://issues.apache.org/jira/browse/KAFKA-3430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3430 stopped by Bill Bejeck. -- > Allow users to set key in KTable.toStream() and KStream >

[jira] [Work started] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

[ https://issues.apache.org/jira/browse/KAFKA-3430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3430 started by Bill Bejeck. -- > Allow users to set key in KTable.toStream() and KStream >

[jira] [Assigned] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

[ https://issues.apache.org/jira/browse/KAFKA-3430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3430: -- Assignee: Bill Bejeck > Allow users to set key in KTable.toStream() and KStream >

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223099#comment-15223099 ] Bill Bejeck commented on KAFKA-3338: Guozhang, Thanks for the response, that all makes perfect sense.

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220957#comment-15220957 ] Bill Bejeck commented on KAFKA-3338: I'm wondering if we need to provide a Serde for the

[jira] [Work started] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3338 started by Bill Bejeck. -- > Add print and writeAsText functions to the Streams DSL >

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15215160#comment-15215160 ] Bill Bejeck commented on KAFKA-3338: Picking this one up. I Searched pull requests and looks like no

<    1   2   3   4   >