diff --git a/devstack/files/monasca-transform/driver.py b/devstack/files/monasca-transform/driver.py
index 0c94ca6..57bd8b8 100644
--- a/devstack/files/monasca-transform/driver.py
+++ b/devstack/files/monasca-transform/driver.py
@@ -13,7 +13,7 @@
 # under the License.
 
 activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
-execfile(activate_this_file, dict(__file__=activate_this_file))
+exec(open(activate_this_file).read(), dict(__file__=activate_this_file))
 
 from monasca_transform.driver.mon_metrics_kafka import invoke
 
diff --git a/devstack/files/monasca-transform/service_runner.py b/devstack/files/monasca-transform/service_runner.py
index c19de04..4928b4a 100644
--- a/devstack/files/monasca-transform/service_runner.py
+++ b/devstack/files/monasca-transform/service_runner.py
@@ -15,7 +15,7 @@
 import sys
 
 activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
-execfile(activate_this_file, dict(__file__=activate_this_file))
+exec(open(activate_this_file).read(), dict(__file__=activate_this_file))
 
 from monasca_transform.service.transform_service import main_service
 
diff --git a/monasca_transform/driver/mon_metrics_kafka.py b/monasca_transform/driver/mon_metrics_kafka.py
index e13b194..e8cfa93 100644
--- a/monasca_transform/driver/mon_metrics_kafka.py
+++ b/monasca_transform/driver/mon_metrics_kafka.py
@@ -118,7 +118,7 @@ class MonMetricsKafkaProcessor(object):
                     # partition = saved_offset_spec[composite_key]
                     from_offsets[
                         TopicAndPartition(spec_topic, spec_partition)
-                    ] = long(spec_until_offset)
+                    ] = int(spec_until_offset)
 
             MonMetricsKafkaProcessor.log_debug(
                 "get_kafka_stream: calling createDirectStream :"