[jira] [Updated] (STORM-2826) KafkaSpoutConfig.builder doesn't set key/value deserializer properties in storm-kafka-client

2017-11-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated STORM-2826: -- Labels: pull-request-available (was: ) > KafkaSpoutConfig.builder doesn't set key/value

[jira] [Commented] (STORM-2819) Ability to natively support JSON serialization in topologies

2017-11-19 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258488#comment-16258488 ] Stig Rohde Døssing commented on STORM-2819: --- You don't need to generate a POJO for each object

[jira] [Created] (STORM-2826) KafkaSpoutConfig.builder doesn't set key/value deserializer properties in storm-kafka-client

2017-11-19 Thread JIRA
Stig Rohde Døssing created STORM-2826: - Summary: KafkaSpoutConfig.builder doesn't set key/value deserializer properties in storm-kafka-client Key: STORM-2826 URL:

[jira] [Commented] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258460#comment-16258460 ] Jungtaek Lim commented on STORM-2824: - To understanding exactly once processing, you may want to

[jira] [Commented] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258382#comment-16258382 ] Stig Rohde Døssing commented on STORM-2824: --- There is already an option to ack tuples

[jira] [Created] (STORM-2825) storm-kafka-client configuration fails with a ClassCastException if "enable.auto.commit" is present in the consumer config map, and the value is a string

2017-11-19 Thread JIRA
Stig Rohde Døssing created STORM-2825: - Summary: storm-kafka-client configuration fails with a ClassCastException if "enable.auto.commit" is present in the consumer config map, and the value is a string Key: STORM-2825

[jira] [Updated] (STORM-2825) storm-kafka-client configuration fails with a ClassCastException if "enable.auto.commit" is present in the consumer config map, and the value is a string

2017-11-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated STORM-2825: -- Labels: pull-request-available (was: ) > storm-kafka-client configuration fails with a

[jira] [Updated] (STORM-2825) storm-kafka-client configuration fails with a ClassCastException if "enable.auto.commit" is present in the consumer config map, and the value is a string

2017-11-19 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2825: -- Affects Version/s: (was: 2.0.0) > storm-kafka-client configuration fails with a

[jira] [Commented] (STORM-2823) Ability to have an option to combine topologies at run time in a single process space

2017-11-19 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258463#comment-16258463 ] Stig Rohde Døssing commented on STORM-2823: --- Storm is a fail-fast system, which means that if

[jira] [Commented] (STORM-2819) Ability to natively support JSON serialization in topologies

2017-11-19 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258874#comment-16258874 ] Stig Rohde Døssing commented on STORM-2819: --- Kryo wasn't picked because Storm needs to serialize

[jira] [Commented] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258781#comment-16258781 ] Anton Alfred commented on STORM-2824: - topology.acker.executors to 0 Yes, this is exactly the config

[jira] [Comment Edited] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258781#comment-16258781 ] Anton Alfred edited comment on STORM-2824 at 11/20/17 3:32 AM: ---

[jira] [Commented] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258787#comment-16258787 ] Jungtaek Lim commented on STORM-2824: - We are saying it to processing "guarantee", so we can't treat

[jira] [Commented] (STORM-2819) Ability to natively support JSON serialization in topologies

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258721#comment-16258721 ] Anton Alfred commented on STORM-2819: - I am trying to question the existence of Kryo for Json. We

[jira] [Commented] (STORM-2823) Ability to have an option to combine topologies at run time in a single process space

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258761#comment-16258761 ] Anton Alfred commented on STORM-2823: - What I am saying is Topology boundary should not be a worker

[jira] [Comment Edited] (STORM-2824) Ability to configure topologies for exactly once processing

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258781#comment-16258781 ] Anton Alfred edited comment on STORM-2824 at 11/20/17 3:33 AM: ---

[jira] [Comment Edited] (STORM-2819) Ability to natively support JSON serialization in topologies

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258721#comment-16258721 ] Anton Alfred edited comment on STORM-2819 at 11/20/17 2:05 AM: --- I am trying

[jira] [Comment Edited] (STORM-2819) Ability to natively support JSON serialization in topologies

2017-11-19 Thread Anton Alfred (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258721#comment-16258721 ] Anton Alfred edited comment on STORM-2819 at 11/20/17 2:04 AM: --- I am trying

[jira] [Commented] (STORM-2823) Ability to have an option to combine topologies at run time in a single process space

2017-11-19 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258774#comment-16258774 ] Jungtaek Lim commented on STORM-2823: - I'm afraid that the origin usage of Storm is in fact opposite,