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

2016-05-03 Thread Bill Bejeck (JIRA)
[ 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 > > > Key

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

2016-04-19 Thread Bill Bejeck (JIRA)
[ 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 > > > Key

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

2016-04-17 Thread Bill Bejeck (JIRA)
[ 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

2016-04-14 Thread Bill Bejeck (JIRA)
[ 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 KTable.to

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

2016-04-14 Thread Bill Bejeck (JIRA)
[ 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

2016-04-11 Thread Bill Bejeck (JIRA)
[ 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

2016-04-11 Thread Bill Bejeck (JIRA)
[ 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

2016-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233247#comment-15233247 ] Bill Bejeck commented on KAFKA-3338: Due to merging/rebase issues closed PR #1187 will

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

2016-04-02 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223099#comment-15223099 ] Bill Bejeck commented on KAFKA-3338: Guozhang, Thanks for the response, that all make

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

2016-03-31 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15220957#comment-15220957 ] Bill Bejeck commented on KAFKA-3338: I'm wondering if we need to provide a Serde for t

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

2016-03-29 Thread Bill Bejeck (JIRA)
[ 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

2016-03-28 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215160#comment-15215160 ] Bill Bejeck commented on KAFKA-3338: Picking this one up. I Searched pull requests an

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

2016-03-28 Thread Bill Bejeck (JIRA)
[ 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 > --

[jira] [Work started] (KAFKA-2836) FAILING TEST: SaslSslTopicMetadataTest

2015-12-18 Thread Bill Bejeck (JIRA)
[ 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 > -- > >

[jira] [Commented] (KAFKA-2836) FAILING TEST: SaslSslTopicMetadataTest

2015-12-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062501#comment-15062501 ] Bill Bejeck commented on KAFKA-2836: Picking this bug up. > FAILING TEST: SaslSslTopi

[jira] [Assigned] (KAFKA-2836) FAILING TEST: SaslSslTopicMetadataTest

2015-12-17 Thread Bill Bejeck (JIRA)
[ 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 > --

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-30 Thread Bill Bejeck (JIRA)
[ 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 instea

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-30 Thread Bill Bejeck (JIRA)
[ 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 getRestoreConsumerCon

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-27 Thread Bill Bejeck (JIRA)
[ 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 us

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-27 Thread Bill Bejeck (JIRA)
[ 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

[jira] [Work stopped] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-27 Thread Bill Bejeck (JIRA)
[ 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 > g

[jira] [Work started] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-27 Thread Bill Bejeck (JIRA)
[ 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 > g

[jira] [Created] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

2015-11-27 Thread Bill Bejeck (JIRA)
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

[jira] [Commented] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-21 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020741#comment-15020741 ] Bill Bejeck commented on KAFKA-2872: There appears to be a test failure (kafka.api.Ss

[jira] [Updated] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-21 Thread Bill Bejeck (JIRA)
[ 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 ToplogyBuilder.addS

[jira] [Work stopped] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-21 Thread Bill Bejeck (JIRA)
[ 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 > source/p

[jira] [Work stopped] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-21 Thread Bill Bejeck (JIRA)
[ 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 > source/p

[jira] [Work started] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-21 Thread Bill Bejeck (JIRA)
[ 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 > source/p

[jira] [Work started] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-20 Thread Bill Bejeck (JIRA)
[ 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 > source/p

[jira] [Created] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

2015-11-20 Thread Bill Bejeck (JIRA)
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

[jira] [Commented] (KAFKA-2058) ProducerTest.testSendWithDeadBroker transient failure

2015-09-28 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933260#comment-14933260 ] Bill Bejeck commented on KAFKA-2058: I've been trying to reproduce this error locally

[jira] [Assigned] (KAFKA-2058) ProducerTest.testSendWithDeadBroker transient failure

2015-09-07 Thread Bill Bejeck (JIRA)
[ 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 > ---

<    1   2   3   4