Manikumar resolved KAFKA-4347.
    Resolution: Invalid

Looks like this is related to Apache Storm Kafka connector. Request you raise 
the issue on Storm project.

> outputStreamId in Kafka spout
> -----------------------------
>                 Key: KAFKA-4347
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4347
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Rahim Dastar
>            Priority: Major
> 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

Reply via email to