Renjie Liu created STORM-2473: --------------------------------- Summary: KafkaTridentSpoutOpaque's implementation is incorrect. Key: STORM-2473 URL: https://issues.apache.org/jira/browse/STORM-2473 Project: Apache Storm Issue Type: Bug Components: storm-kafka-client Affects Versions: 1.x Reporter: Renjie Liu Assignee: Renjie Liu
The coordinator relies on emitter to start subscription, this is in correct since coordinator and emitter may run on different machines. -- This message was sent by Atlassian JIRA (v6.3.15#6346)