You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Haewan Jeong (JIRA)" <ji...@apache.org> on 2017/06/23 05:19:00 UTC
[jira] [Updated] (STORM-2568) Wrong configuration 'groupid' to get
lag for new kafka spout
[ https://issues.apache.org/jira/browse/STORM-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Haewan Jeong updated STORM-2568:
--------------------------------
Description:
Hello
I've tried to use storm-kafka-monitor, and it works fine on command line If I changed 'toollib/storm-kafka-monitor-*.jar' to 'toollib/storm-kafka-monitor-1.1.0.jar'.
but it gives empty result when I call below api.
{code}
/api/v1/topology/:id/lag
...
{
"MySpoutName": {
"spoutLagResult": {},
"spoutId": "MySpoutName",
"spoutType": "KAFKA"
}
}
{code}
I think that needs to fix "groupid" to "group.id" in TopologySpoutLag.java
{code}
package org.apache.storm.utils;
public class TopologySpoutLag {
...
commands.add((String)jsonConf.get(configKeyPrefix + "groupid"));
{code}
{code}
package org.apache.storm.kafka.spout;
public class KafkaSpoutConfig<K, V> implements Serializable {
...
public String getConsumerGroupId() {
return (String)this.kafkaProps.get("group.id");
}
...
public KafkaSpoutConfig.Builder<K, V> setGroupId(String id) {
return this.setProp("group.id", id);
}
{code}
was:
Hello
I've tried to use storm-kafka-monitor, and it works fine on command line If I changed 'toollib/storm-kafka-monitor-*.jar' to 'toollib/storm-kafka-monitor-1.1.0.jar'.
but it gives empty result when I call below api.
{code}
/api/v1/topology/:id/lag
...
{
"MySpoutName": {
"spoutLagResult": {},
"spoutId": "MySpoutName",
"spoutType": "KAFKA"
}
}
{code}
I think need to fix "groupid" to "group.id" in TopologySpoutLag.java
{code}
package org.apache.storm.utils;
public class TopologySpoutLag {
...
commands.add((String)jsonConf.get(configKeyPrefix + "groupid"));
{code}
{code}
package org.apache.storm.kafka.spout;
public class KafkaSpoutConfig<K, V> implements Serializable {
...
public String getConsumerGroupId() {
return (String)this.kafkaProps.get("group.id");
}
...
public KafkaSpoutConfig.Builder<K, V> setGroupId(String id) {
return this.setProp("group.id", id);
}
{code}
> Wrong configuration 'groupid' to get lag for new kafka spout
> ------------------------------------------------------------
>
> Key: STORM-2568
> URL: https://issues.apache.org/jira/browse/STORM-2568
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
> Affects Versions: 1.1.0
> Reporter: Haewan Jeong
>
> Hello
> I've tried to use storm-kafka-monitor, and it works fine on command line If I changed 'toollib/storm-kafka-monitor-*.jar' to 'toollib/storm-kafka-monitor-1.1.0.jar'.
> but it gives empty result when I call below api.
> {code}
> /api/v1/topology/:id/lag
> ...
> {
> "MySpoutName": {
> "spoutLagResult": {},
> "spoutId": "MySpoutName",
> "spoutType": "KAFKA"
> }
> }
> {code}
> I think that needs to fix "groupid" to "group.id" in TopologySpoutLag.java
> {code}
> package org.apache.storm.utils;
> public class TopologySpoutLag {
> ...
> commands.add((String)jsonConf.get(configKeyPrefix + "groupid"));
> {code}
> {code}
> package org.apache.storm.kafka.spout;
> public class KafkaSpoutConfig<K, V> implements Serializable {
> ...
> public String getConsumerGroupId() {
> return (String)this.kafkaProps.get("group.id");
> }
> ...
> public KafkaSpoutConfig.Builder<K, V> setGroupId(String id) {
> return this.setProp("group.id", id);
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)