[
https://issues.apache.org/jira/browse/KAFKA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
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
(v7.6.3#76005)
