Github user anishek commented on a diff in the pull request:
https://github.com/apache/storm/pull/601#discussion_r33414016
--- Diff: external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java ---
@@ -29,6 +29,7 @@
// setting for how often to save the current kafka offset to ZooKeeper
public long stateUpdateIntervalMs = 2000;
+ public String emitStreamId;
--- End diff --
you are right i didnt look at the code too closely, I had a overridden
method in PartitionManager with the default stream. I thought anyone else using
the old method would automatically go through that. Though thinking now i
looked at all the usages and there is only one in the kafkaSpout so i will do
another pull request with the changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
