[jira] [Commented] (STORM-2155) Come up with design for improving the streams api guarantees

[ https://issues.apache.org/jira/browse/STORM-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904343#comment-15904343 ] Arun Mahadevan commented on STORM-2155: --- Lets keep this unassigned. Whoever interest

[jira] [Assigned] (STORM-2155) Come up with design for improving the streams api guarantees

[ https://issues.apache.org/jira/browse/STORM-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan reassigned STORM-2155: - Assignee: (was: Satish Duggana) > Come up with design for improving the streams api g

[jira] [Commented] (STORM-2363) Provide configuration to set the number of RollingWindow

[ https://issues.apache.org/jira/browse/STORM-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904309#comment-15904309 ] liuzhaokun commented on STORM-2363: --- Hi[~kabhwan] This is an optimized design.And it's c

[jira] [Updated] (STORM-2404) Give exactly once support in storm core.

[ https://issues.apache.org/jira/browse/STORM-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated STORM-2404: -- Component/s: storm-core > Give exactly once support in storm core. > ---

[jira] [Created] (STORM-2404) Give exactly once support in storm core.

Satish Duggana created STORM-2404: - Summary: Give exactly once support in storm core. Key: STORM-2404 URL: https://issues.apache.org/jira/browse/STORM-2404 Project: Apache Storm Issue Type: I

[jira] [Assigned] (STORM-2155) Come up with design for improving the streams api guarantees

[ https://issues.apache.org/jira/browse/STORM-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned STORM-2155: - Assignee: Satish Duggana > Come up with design for improving the streams api guarantees >

[jira] [Resolved] (STORM-2361) Kafka spout - after leader change, it stops committing offsets to ZK

[ https://issues.apache.org/jira/browse/STORM-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2361. - Resolution: Fixed Assignee: Ernestas Vaiciukevičius Fix Version/s: 1.0.4

[jira] [Commented] (STORM-2296) Kafka spout - no duplicates on leader changes

[ https://issues.apache.org/jira/browse/STORM-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903398#comment-15903398 ] Jungtaek Lim commented on STORM-2296: - Ported back to 1.0.x branch to apply STORM-2361

[jira] [Updated] (STORM-2296) Kafka spout - no duplicates on leader changes

[ https://issues.apache.org/jira/browse/STORM-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2296: Fix Version/s: 1.0.4 > Kafka spout - no duplicates on leader changes > -

[jira] [Created] (STORM-2403) Fix KafkaBolt test failure: tick tuple should not be acked

Jungtaek Lim created STORM-2403: --- Summary: Fix KafkaBolt test failure: tick tuple should not be acked Key: STORM-2403 URL: https://issues.apache.org/jira/browse/STORM-2403 Project: Apache Storm

[jira] [Updated] (STORM-2402) KafkaSpout sub-classes should be able to customize tuple processing

[ https://issues.apache.org/jira/browse/STORM-2402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Klessing updated STORM-2402: --- Description: We need a {{KafkaSpout}} that writes unprocessable records to a "dead-letter-topi

[jira] [Created] (STORM-2402) KafkaSpout sub-classes should be able to customize tuple processing

Daniel Klessing created STORM-2402: -- Summary: KafkaSpout sub-classes should be able to customize tuple processing Key: STORM-2402 URL: https://issues.apache.org/jira/browse/STORM-2402 Project: Apache

[jira] [Updated] (STORM-2296) Kafka spout - no duplicates on leader changes

[ https://issues.apache.org/jira/browse/STORM-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ernestas Vaiciukevičius updated STORM-2296: --- Description: Current behavior of Kafka spout emits duplicate tuples whenever K

[jira] [Resolved] (STORM-2353) Test kafka-clients:0.10.1.1 failed due to deprecated call from external Kafka unit dependency

[ https://issues.apache.org/jira/browse/STORM-2353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2353. - Resolution: Fixed Assignee: Luke Sun Fix Version/s: 1.1.0 2.0.0

[jira] [Commented] (STORM-2349) Add one RocketMQ plugin for the Apache Storm

[ https://issues.apache.org/jira/browse/STORM-2349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902640#comment-15902640 ] Xin Wang commented on STORM-2349: - [~kabhwan] The RocketMQ team member(rocketmq-storm orig