[
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 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
[
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
>
[
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
>
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
>
[
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.
[
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
[
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
[
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
[
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.
>
[
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"
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
>
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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,
[
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
> -
>
>
[
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
[
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://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
[
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
> -
>
>
[
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
>
[
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
[
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
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
[
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.
>
[
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
[
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
[
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
[
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
>
[
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
[
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]
[
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.
>
[
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://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
>
[
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
[
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
[
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
>
[
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
[
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
>
[
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
>
[
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
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
[
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
>
[
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:
[
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
> ---
>
>
[
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
[
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
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
[
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
>
[
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
[
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
[
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()
>
[
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
[
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()
>
[
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
>
[
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
>
>
>
[
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
>
>
>
[
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
>
>
>
[
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
>
[
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
>
>
>
[
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
>
>
>
[
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
>
>
>
[
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
[
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
>
[
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
>
[
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
>
[
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.
[
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
[
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
>
201 - 300 of 319 matches
Mail list logo