diff --git a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
index 445f8f2b..ece07fec 100644
--- a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
+++ b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
@@ -110,7 +110,7 @@ def process_rosbag(self,rosbag2_path):
 
     def create_record_from_msg(self, msg, measurement_name):
 
-        topic = msg.channel.topic
+        topic = msg.channel.topic[1:]
         ros_msg = msg.ros_msg
         msg_attributes = self.extract_attributes(ros_msg)
         msg_timestamp = msg.publish_time_ns
@@ -133,7 +133,7 @@ def create_record_from_msg(self, msg, measurement_name):
                 records.append(f"{attr_name}={attr_value}")
 
 
-        return f"{measurement_name},topic_name={topic}," + ",".join(records) + f" timestamp={msg_timestamp}"
+        return f"{measurement_name},topic_name={topic} " + ",".join(records) + f",timestamp={msg_timestamp} {msg_timestamp}"
 
 
     def extract_attributes(self, obj, parent_attr=None):