You can provide it under grouping. Check GroupingDef. Pasting an example below.



  - name: "kafka --> split" # name isn't used (placeholder for logging, UI, etc.)

    from: "kafka-spout"

    to: "splitsentence"


      type: SHUFFLE

      streamId: “mystream”



From: "Huang, Zhipeng" <>
Reply-To: "" <>
Date: Friday, November 10, 2017 at 2:56 PM
To: "" <>
Subject: storm flux API - emit to specific streamId


Hi Apache Storm Team,


May I have a quick question – how to configure the streamId in yaml file,

so in Bolt we can emit the tuple to specified stream? Thanks!



Currently the StreamDef don’t have “streamId” available in V1.1.1, or even on Github.


public class StreamDef {


    private String name; // not used, placeholder for GUI, etc.

    private String from;

    private String to;

private GroupingDef grouping;





CONFIDENTIALITY NOTICE This e-mail message and any attachments are only for the use of the intended recipient and may contain information that is privileged, confidential or exempt from disclosure under applicable law. If you are not the intended recipient, any disclosure, distribution or other use of this e-mail message or attachments is prohibited. If you have received this e-mail message in error, please delete and notify the sender immediately. Thank you.