[
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
[
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
[
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 KTable.to
[
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&focusedCommentId=15233247#comment-15233247
]
Bill Bejeck commented on KAFKA-3338:
Due to merging/rebase issues closed PR #1187 will
[
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
[
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
[
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-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
[
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-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-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
[
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-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Component/s: kafka streams
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instea
[
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
[
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
[
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
]
Work on KAFKA-2902 stopped by Bill Bejeck.
--
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of
> g
[
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
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-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
[
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
[
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
[
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
[
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
[
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
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-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
[
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
> ---
301 - 332 of 332 matches
Mail list logo