def get_mock_stream_id(id="<STR_LIT>", component_name="<STR_LIT>"):
stream_id = topology_pb2.StreamId()<EOL>stream_id.id = id<EOL>stream_id.component_name = component_name<EOL>return stream_id<EOL>
Returns a mock protobuf StreamId from topology_pb2