diff --git a/scripts/image_consumer.py b/scripts/image_consumer.py
old mode 100644
new mode 100755
index ddfbd6b..6fa7dc1
--- a/scripts/image_consumer.py
+++ b/scripts/image_consumer.py
@@ -37,7 +37,7 @@ def consume_images(kafka_topic: str, kafka_server: str):
 
     parser = argparse.ArgumentParser()
 
-    parser.add_argument("-t", "--topic", default="heron.sim-test.wrist-camera", help="Kafka topic name") 
+    parser.add_argument("-t", "--topic", default="ugv.image.body", help="Kafka topic name") 
     parser.add_argument("-s", "--server", default="10.2.0.8:9092", help="Kafka bootstrap server")
 
     args = parser.parse_args()
diff --git a/src/kafka_publisher.py b/src/kafka_publisher.py
index 7980c65..7a34268 100755
--- a/src/kafka_publisher.py
+++ b/src/kafka_publisher.py
@@ -14,7 +14,6 @@
 
 
 class KafkaPublisher:
-    # TODO need to make kafka topics!!
     """
     takes a yaml file with:
     - ros msg types
@@ -130,6 +129,7 @@ def create_kafka_topics(self, topics_dict: dict) -> None:
             rospy.logerr("All kafka topics already exist.")
 
     def image_callback(self, msg, kafka_topic: str) -> None:
+        ### also log to Robotnik
         try:
             # convert ros image to compressed jpeg and base64 encode
             cv_image = self.bridge.imgmsg_to_cv2(