diff --git a/kafka/kafka-consumer.py b/kafka/kafka-consumer.py
index 3f405d8..0b45f6f 100644
--- a/kafka/kafka-consumer.py
+++ b/kafka/kafka-consumer.py
@@ -20,7 +20,7 @@
 
 
 class ConsumerExample(object):
-    def __init__(self, consul_endpoint, topic="heartbeat.voltha", runtime=60):
+    def __init__(self, consul_endpoint, topic="voltha.heartbeat", runtime=60):
         self.topic = topic
         self.runtime = runtime
         self.kafka_endpoint = get_endpoint_from_consul(consul_endpoint,
@@ -105,7 +105,7 @@
 
     parser.add_argument("-t", "--topic",
                         help="topic to listen from",
-                        default="heartbeat.voltha")
+                        default="voltha.heartbeat")
 
     parser.add_argument("-r", "--runtime",
                         help="total runtime",