You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Rahim Dastar (JIRA)" <ji...@apache.org> on 2016/10/26 08:16:58 UTC

[jira] [Created] (KAFKA-4347) outputStreamId in Kafka spout

Rahim Dastar created KAFKA-4347:
-----------------------------------

             Summary: outputStreamId in Kafka spout
                 Key: KAFKA-4347
                 URL: https://issues.apache.org/jira/browse/KAFKA-4347
             Project: Kafka
          Issue Type: Bug
            Reporter: Rahim Dastar


If you set outputStreamId in SpoutConfig for kafka spout, topology sends tuples to another stream. The wrong stream name is topicName.
In ParttionManager class  collector.emit(_spoutConfig.topic, tup, new KafkaMessageId(_partition, toEmit.offset())); should change to 
collector.emit(_spoutConfig.outputStreamId, tup, new KafkaMessageId(_partition, toEmit.offset()));.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)