[
https://issues.apache.org/jira/browse/KAFKA-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-2058:
--
Assignee: Bill Bejeck
> ProducerTest.testSendWithDeadBroker transient failure
>
[
https://issues.apache.org/jira/browse/KAFKA-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933260#comment-14933260
]
Bill Bejeck commented on KAFKA-2058:
I've been trying to reproduce this error locally without much
[
https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15062501#comment-15062501
]
Bill Bejeck commented on KAFKA-2836:
Picking this bug up.
> FAILING TEST: SaslSslTopicMetadataTest
>
[
https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-2836:
--
Assignee: Bill Bejeck
> FAILING TEST: SaslSslTopicMetadataTest
>
[
https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2836 started by Bill Bejeck.
--
> FAILING TEST: SaslSslTopicMetadataTest
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Description:
When starting a KafkaStreaming instance the StreamingConfig.getConsumerConfigs
method
Bill Bejeck created KAFKA-2902:
--
Summary: StreamingConfig getConsumerConfiigs uses
getRestoreConsumerConfigs instead of getBaseConsumerConfigs
Key: KAFKA-2902
URL: https://issues.apache.org/jira/browse/KAFKA-2902
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2902 started by Bill Bejeck.
--
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of
>
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2902 stopped by Bill Bejeck.
--
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of
>
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Status: Patch Available (was: Open)
Changes made for using getBaseConsumerProps from StreamingConfig
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Component/s: kafka streams
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Component/s: (was: kafka streams)
> StreamingConfig getConsumerConfiigs uses
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 stopped by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 stopped by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2872:
---
Fix Version/s: 0.9.0.0
Status: Patch Available (was: Open)
Updated the
Bill Bejeck created KAFKA-2872:
--
Summary: Error starting KafkaStream caused by sink not being
connected to parent source/processor nodes
Key: KAFKA-2872
URL: https://issues.apache.org/jira/browse/KAFKA-2872
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 started by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
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-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:
---
Fix Version/s: (was: 0.10.0.1)
0.10.1.0
Affects Version/s:
[
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
>
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-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
[
https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-3338:
--
Assignee: Bill Bejeck
> Add print and writeAsText functions to the Streams DSL
>
[
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
>
[
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: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: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-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: (was: Bill Bejeck)
> Optimize Aggregation Outputs
>
[
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
]
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-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-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
]
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-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-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: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-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:all-tabpanel
]
Work on KAFKA-3973 started by Bill Bejeck.
--
> 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
[
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-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-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
]
Bill Bejeck updated KAFKA-3989:
---
Fix Version/s: 0.10.1.0
> Add JMH module for Benchmarks
> -
>
>
[
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-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-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-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=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=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=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-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=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-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-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 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-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-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-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-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
[
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-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-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855204#comment-15855204
]
Bill Bejeck commented on KAFKA-4731:
[~mjsax] Is this Jira pending any further API redesign
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4791:
--
Assignee: Bill Bejeck
> Kafka Streams - unable to add state stores when using wildcard topics
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880782#comment-15880782
]
Bill Bejeck commented on KAFKA-4791:
picking this one up.
> Kafka Streams - unable to add state
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881018#comment-15881018
]
Bill Bejeck commented on KAFKA-4791:
Fair enough. I did not look into the issue at all, at first
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881018#comment-15881018
]
Bill Bejeck edited comment on KAFKA-4791 at 2/23/17 6:56 PM:
-
Fair enough. I
[
https://issues.apache.org/jira/browse/KAFKA-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4652:
--
Assignee: Bill Bejeck
> Improve test coverage KStreamBuilder
>
[
https://issues.apache.org/jira/browse/KAFKA-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862883#comment-15862883
]
Bill Bejeck commented on KAFKA-4652:
Misses these as well with auto-offset reset PR, picking up.
>
[
https://issues.apache.org/jira/browse/KAFKA-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4731:
--
Assignee: Bill Bejeck
> Add event-based session windows
> ---
>
>
[
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 TopologyBuilder
>
[
https://issues.apache.org/jira/browse/KAFKA-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826055#comment-15826055
]
Bill Bejeck commented on KAFKA-4662:
I missed these with my PR, picking this one up.
> Improve test
[
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
[
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-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-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: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=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-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-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4791 started by Bill Bejeck.
--
> Kafka Streams - unable to add state stores when using wildcard topics on the
>
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4791:
---
Status: Patch Available (was: In Progress)
> Kafka Streams - unable to add state stores when using
[
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"
1 - 100 of 318 matches
Mail list logo