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

Posted to dev@storm.apache.org by Rohit Kumar <my...@gmail.com> on 2018/11/18 18:20:49 UTC

Unable to send data to a kafka topic using kfkabolt

Hi,

I want to send some message to a kafka topic using kafkabolt using
outputcollector.emit().

I created a kafkabolt with topicselector as FieldNameTopicSelector.

But i don't understand how i should emit so that data gets routed to
different bolt and how we can provide a topic name while emitting.

Thanks,
Rohit