[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-04 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352004#comment-16352004 ] Jungtaek Lim commented on STORM-2914: - Thanks [~Srdo], merged into master. Since there's some diverge

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-04 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352003#comment-16352003 ] Jungtaek Lim commented on STORM-2914: - Thanks [~Srdo], merged into master. Since there's some diverge

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-03 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351584#comment-16351584 ] Hugo Louro commented on STORM-2914: --- [~Srdo] Thanks for working on this over the weekend. I am going to

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-03 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351308#comment-16351308 ] Alexandre Vermeerbergen commented on STORM-2914: Hello [~hmclouro] +1 for your proposal

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-02 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351147#comment-16351147 ] Hugo Louro commented on STORM-2914: --- [~Srdo][~kabhwan][~avermeerbergen] Let’s try to quickly agree on

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Priyank Shah (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349477#comment-16349477 ] Priyank Shah commented on STORM-2914: - [~avermeerbergen] Not sure how the javadoc and sources jar got

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349373#comment-16349373 ] Jungtaek Lim commented on STORM-2914: - [~Srdo] You've got my points. Thanks for reading my comment

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349315#comment-16349315 ] Alexandre Vermeerbergen commented on STORM-2914: Hello [~Srdo] Regarding

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349137#comment-16349137 ] Stig Rohde Døssing commented on STORM-2914: --- [~avermeerbergen] Yes, those logs are expected to

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Priyank Shah (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349071#comment-16349071 ] Priyank Shah commented on STORM-2914: - [~avermeerbergen] That jar is for displaying the Kafka spout

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348563#comment-16348563 ] Alexandre Vermeerbergen commented on STORM-2914: [~Srdo] Also I noticed that in the

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-02-01 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348558#comment-16348558 ] Alexandre Vermeerbergen commented on STORM-2914: Hello [~Srdo] I have build

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-31 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347797#comment-16347797 ] Jungtaek Lim commented on STORM-2914: - Correction: If new model of backpressure doesn't adjust a rate

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-31 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347675#comment-16347675 ] Jungtaek Lim commented on STORM-2914: - [~hmclouro] [~Srdo] As I showed the example of Flink and Spark

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346235#comment-16346235 ] Jungtaek Lim commented on STORM-2914: - Whatever we decide, it may be better to document such guide so

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346232#comment-16346232 ] Jungtaek Lim commented on STORM-2914: - [~hmclouro]

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346215#comment-16346215 ] Hugo Louro commented on STORM-2914: --- [~kabhwan] I am OK with supporting only at-most-once or

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346102#comment-16346102 ] Hugo Louro commented on STORM-2914: --- [~Srdo] [~kabhwan] [~avermeerbergen] the decision to keep or not

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345533#comment-16345533 ] Hugo Louro commented on STORM-2914: --- [~Srdo] I am reviewing this patches today. I have going over the

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-30 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345522#comment-16345522 ] Stig Rohde Døssing commented on STORM-2914: --- [~avermeerbergen] I have a 1.x branch here

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-28 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342987#comment-16342987 ] Alexandre Vermeerbergen commented on STORM-2914: [~Srdo] We do set

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342365#comment-16342365 ] Stig Rohde Døssing commented on STORM-2914: --- {quote} My belief is that our alerting topology

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342327#comment-16342327 ] Jungtaek Lim commented on STORM-2914: - [~Srdo] Got it. Thanks for explanation. So it could make much

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342319#comment-16342319 ] Stig Rohde Døssing commented on STORM-2914: --- [~kabhwan] It would be good to figure out why

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342316#comment-16342316 ] Jungtaek Lim commented on STORM-2914: - FYI to [~avermeerbergen], the behavior of back pressure will be

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342312#comment-16342312 ] Jungtaek Lim commented on STORM-2914: - So I don't think we even need to have NONE processing

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342305#comment-16342305 ] Jungtaek Lim commented on STORM-2914: - I feel [~avermeerbergen]'s issue is unlikely to having

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342254#comment-16342254 ] Stig Rohde Døssing commented on STORM-2914: --- [~hmclouro] Thanks. I have most of the code changes

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Hugo Louro (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342243#comment-16342243 ] Hugo Louro commented on STORM-2914: --- [~Srdo] I am currently with limited Internet access. I will get my

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342242#comment-16342242 ] Stig Rohde Døssing commented on STORM-2914: --- [~avermeerbergen] Regarding your use case, you

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread Alexandre Vermeerbergen (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342221#comment-16342221 ] Alexandre Vermeerbergen commented on STORM-2914: Hello [~Srdo], We use auto-commit when

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

2018-01-27 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342145#comment-16342145 ] Stig Rohde Døssing commented on STORM-2914: --- Ping [~hmclouro] and [~avermeerbergen], I'd