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

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349477#comment-16349477 ] Priyank Shah commented on STORM-2914: - [~avermeerbergen] Not sure how the javadoc and

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

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349071#comment-16349071 ] Priyank Shah commented on STORM-2914: - [~avermeerbergen] That jar is for displaying th

[jira] [Assigned] (STORM-1288) port backtype.storm.grouping-test to java

[ https://issues.apache.org/jira/browse/STORM-1288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah reassigned STORM-1288: --- Assignee: Priyank Shah > port backtype.storm.grouping-test to java > ---

[jira] [Commented] (STORM-2647) Reduce Number of Threads running in the Worker

[ https://issues.apache.org/jira/browse/STORM-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16093915#comment-16093915 ] Priyank Shah commented on STORM-2647: - [~roshan_naik] If you dont mind i would like to

[jira] [Assigned] (STORM-2647) Reduce Number of Threads running in the Worker

[ https://issues.apache.org/jira/browse/STORM-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah reassigned STORM-2647: --- Assignee: Priyank Shah > Reduce Number of Threads running in the Worker > ---

[jira] [Commented] (STORM-2600) Improve or replace storm-kafka-monitor

[ https://issues.apache.org/jira/browse/STORM-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062568#comment-16062568 ] Priyank Shah commented on STORM-2600: - [~Srdo] You are right. My bad. getComponentConf

[jira] [Commented] (STORM-2600) Improve or replace storm-kafka-monitor

[ https://issues.apache.org/jira/browse/STORM-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062505#comment-16062505 ] Priyank Shah commented on STORM-2600: - [~Srdo] Regarding first point, because the lag

[jira] [Commented] (STORM-2568) 'api/vi/topology/:id/lag' returns empty json {}

[ https://issues.apache.org/jira/browse/STORM-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16061287#comment-16061287 ] Priyank Shah commented on STORM-2568: - [~kabhwan] I can create a PR if [~haewanj] deci

[jira] [Commented] (STORM-2562) Use stronger key size for blow fish key generator and get rid of stack trace

[ https://issues.apache.org/jira/browse/STORM-2562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056290#comment-16056290 ] Priyank Shah commented on STORM-2562: - PR for master https://github.com/apache/storm/p

[jira] [Created] (STORM-2562) Use stronger key size for blow fish key generator and get rid of stack trace

Priyank Shah created STORM-2562: --- Summary: Use stronger key size for blow fish key generator and get rid of stack trace Key: STORM-2562 URL: https://issues.apache.org/jira/browse/STORM-2562 Project: Apa

[jira] [Resolved] (STORM-2512) Change KafkaSpoutConfig in storm-kafka-client to make it work with flux

[ https://issues.apache.org/jira/browse/STORM-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah resolved STORM-2512. - Resolution: Fixed > Change KafkaSpoutConfig in storm-kafka-client to make it work with flux >

[jira] [Created] (STORM-2538) New kafka spout emits duplicate tuples

Priyank Shah created STORM-2538: --- Summary: New kafka spout emits duplicate tuples Key: STORM-2538 URL: https://issues.apache.org/jira/browse/STORM-2538 Project: Apache Storm Issue Type: Bug

[jira] [Commented] (STORM-2512) Change KafkaSpoutConfig in storm-kafka-client to make it work with flux

[ https://issues.apache.org/jira/browse/STORM-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009178#comment-16009178 ] Priyank Shah commented on STORM-2512: - https://github.com/apache/storm/pull/2115 https

[jira] [Created] (STORM-2512) Change KafkaSpoutConfig in storm-kafka-client to make it work with flux

Priyank Shah created STORM-2512: --- Summary: Change KafkaSpoutConfig in storm-kafka-client to make it work with flux Key: STORM-2512 URL: https://issues.apache.org/jira/browse/STORM-2512 Project: Apache S

[jira] [Closed] (STORM-2417) Storm kafka monitor throws IllegalArgumentException if there is no data in kafka topic

[ https://issues.apache.org/jira/browse/STORM-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah closed STORM-2417. --- Resolution: Won't Fix > Storm kafka monitor throws IllegalArgumentException if there is no data in >

[jira] [Updated] (STORM-2417) Storm kafka monitor throws IllegalArgumentException if there is no data in kafka topic

[ https://issues.apache.org/jira/browse/STORM-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah updated STORM-2417: Description: If a topology has a kafka spout in it and if kafka topic does not have any data or topo

[jira] [Updated] (STORM-2417) Storm kafka monitor throws IllegalArgumentException if there is no data in kafka topic

[ https://issues.apache.org/jira/browse/STORM-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah updated STORM-2417: Summary: Storm kafka monitor throws IllegalArgumentException if there is no data in kafka topic (wa

[jira] [Created] (STORM-2417) Storm kafka monitor throws null pointer exception if there is no data in kafka topic

Priyank Shah created STORM-2417: --- Summary: Storm kafka monitor throws null pointer exception if there is no data in kafka topic Key: STORM-2417 URL: https://issues.apache.org/jira/browse/STORM-2417 Proj

[jira] [Created] (STORM-2378) Implement Kinesis Bolt

Priyank Shah created STORM-2378: --- Summary: Implement Kinesis Bolt Key: STORM-2378 URL: https://issues.apache.org/jira/browse/STORM-2378 Project: Apache Storm Issue Type: Improvement

[jira] [Commented] (STORM-2377) Storm UI in secure mode should provide read-only option

[ https://issues.apache.org/jira/browse/STORM-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881514#comment-15881514 ] Priyank Shah commented on STORM-2377: - [~sriharsha] I would like to work on this too

[jira] [Assigned] (STORM-2377) Storm UI in secure mode should provide read-only option

[ https://issues.apache.org/jira/browse/STORM-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyank Shah reassigned STORM-2377: --- Assignee: Priyank Shah > Storm UI in secure mode should provide read-only option > --

[jira] [Commented] (STORM-2375) New KafkaSpout should support reading from user specified offset/timestamp

[ https://issues.apache.org/jira/browse/STORM-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881028#comment-15881028 ] Priyank Shah commented on STORM-2375: - [~sriharsha] I would like to work on this. > N

[jira] [Commented] (STORM-2376) New KafkaSpout security integration tests

[ https://issues.apache.org/jira/browse/STORM-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881031#comment-15881031 ] Priyank Shah commented on STORM-2376: - [~sriharsha] I would like to work on this. > N

[jira] [Commented] (STORM-2319) Remove hadoop-auth depeendency and add spnego filter in storm-core

[ https://issues.apache.org/jira/browse/STORM-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881020#comment-15881020 ] Priyank Shah commented on STORM-2319: - [~sriharsha] I would like to work on this. > R

[jira] [Commented] (STORM-2226) New kafka spout offset lag tool does not work for secured kafka setup

[ https://issues.apache.org/jira/browse/STORM-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707548#comment-15707548 ] Priyank Shah commented on STORM-2226: - https://github.com/apache/storm/pull/1806 > Ne

[jira] [Created] (STORM-2226) New kafka spout offset lag tool does not work for secured kafka setup

Priyank Shah created STORM-2226: --- Summary: New kafka spout offset lag tool does not work for secured kafka setup Key: STORM-2226 URL: https://issues.apache.org/jira/browse/STORM-2226 Project: Apache Sto