[ 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)