diff --git a/voltha/adapters/openolt/openolt_packet.py b/voltha/adapters/openolt/openolt_packet.py
index cfd838c..a3ac84b 100644
--- a/voltha/adapters/openolt/openolt_packet.py
+++ b/voltha/adapters/openolt/openolt_packet.py
@@ -45,7 +45,9 @@
 
     def packet_thread(self):
         self.log.debug('openolt packet-out thread starting')
-        KConsumer(self.packet_process, 'voltha.pktout')
+        KConsumer(self.packet_process,
+                  'voltha.pktout-{}'.format(
+                      self.device.data_model.logical_device_id))
 
     def packet_process(self, topic, msg):