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

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

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

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

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

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

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

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

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

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

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

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

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

Re: [GitHub] kafka pull request: KAFKA-3420 Allow users to set key in KTable.to...

Sorry - This PR is actually for KAFKA-3430, I entered the wrong number, I have updated the title on the PR On Thu, Apr 14, 2016 at 10:41 PM, bbejeck wrote: > GitHub user bbejeck opened a pull request: > > https://github.com/apache/kafka/pull/1222 > > KAFKA-3420

Re: [jira] [Commented] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit

Sorry - this message is in error, I entered the wrong Jira number when issuing the pull request, I have updated the title on the PR. On Thu, Apr 14, 2016 at 10:42 PM, ASF GitHub Bot (JIRA) wrote: > > [ >

[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

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

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

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

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

[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

[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

[jira] [Assigned] (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 ] Bill Bejeck reassigned KAFKA-3338: -- Assignee: Bill Bejeck > Add print and writeAsText functions to the Streams

Re: KStreams Proposal

To(topic, ...)"? > > Guozhang > > > On Sat, Mar 12, 2016 at 12:20 PM, Bill Bejeck <bbej...@gmail.com> wrote: > > > Hi All, > > > > While working with KStream/KStreamImp I discovered that there does not > seem > > to be any way to connect the

KStreams Proposal

Hi All, While working with KStream/KStreamImp I discovered that there does not seem to be any way to connect the results of the KStream.process method with a sink node. I'd like to propose an addition to the API a "processTo" method. I've looked at and used the "transform", "reduceByKey" and

kafka streams

All, I'm pretty excited about kafka-streams and I've written a blog (first of 2-3) on the subject, and I'd thought I'd share. Thanks, Bill

[jira] [Work started] (KAFKA-2836) 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: SaslSslTopicMetadataT

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

[ 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: SaslSslTopicMetadataT

[jira] [Assigned] (KAFKA-2836) 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: SaslSslTopicMetadataT

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

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

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

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

Re: Possible StreamingConfig Bug

t; >>> Hello Bill, >>> >>> Thanks for reporting it, this is a valid issue, could you create a >> ticket? >>> >>> Guozhang >>> >>>> On Fri, Nov 27, 2015 at 6:19 AM, Bill Bejeck <bbej...@gmail.com> wrote: >

Possible StreamingConfig Bug

All, When starting KafkaStreaming I'm getting the following error (even when explicitly setting the groupId with props.put("group.id","test-consumer-group") ); Exception in thread "StreamThread-1" org.apache.kafka.common.KafkaException: org.apache.kafka.common.errors.ApiException: The configured

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

[ 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

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

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] [Work started] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

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

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

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

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

[ 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-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

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

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

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

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

[ 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

Potential KafkaStreaming Bug

Hi All, I'm starting to experiment with the lower-level Processor Client API found on the KIP-28 wiki. When starting the KafkaStream I get the following Exception: Exception in thread "main" java.util.NoSuchElementException: id: SINK at

Re: Potential KafkaStreaming Bug

ns here: > > https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes > > Guozhang > > On Fri, Nov 20, 2015 at 8:32 AM, Bill Bejeck <bbej...@gmail.com> wrote: > > > Hi All, > > > > I'm starting to experiment with the lower-level Processor C

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

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] [Work started] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

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

[jira] [Commented] (KAFKA-2058) 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

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

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

Re: Contributor List

and let me know your > user name. I'll add you to the list. > > On Fri, Sep 4, 2015 at 4:33 PM, Bill Bejeck <bbej...@gmail.com> wrote: > > > Hi can i get added to the contributor list? I'd like to take crack at > > KAFKA-2058 <https://issues.apache.org/jira/browse/KAFKA-2058> > > > > Thanks! > > > > Bill Bejeck > > >

Re: Contributor List

4, 2015 at 4:33 PM, Bill Bejeck <bbej...@gmail.com> wrote: > > > Hi can i get added to the contributor list? I'd like to take crack at > > KAFKA-2058 <https://issues.apache.org/jira/browse/KAFKA-2058> > > > > Thanks! > > > > Bill Bejeck > > >

Contributor List

Hi can i get added to the contributor list? I'd like to take crack at KAFKA-2058 <https://issues.apache.org/jira/browse/KAFKA-2058> Thanks! Bill Bejeck

Re: Jira tickets for starter bugs

/ On Thu, Aug 28, 2014 at 7:00 PM, Bill Bejeck bbej...@gmail.com wrote: Hi, For the starter bugs, do I need to have the jira ticket assigned to me, or do I just do the work and submit a pull request? Thanks, Bill

<    5   6   7   8   9   10