| commit | a3bcfe11b2f15740747b0b969c71debccc20a7c6 | [log] [tgz] |
|---|---|---|
| author | Shad Ansari <shad@opennetworking.org> | Sat Apr 13 11:46:28 2019 -0700 |
| committer | Shad Ansari <shad@opennetworking.org> | Fri May 17 05:52:04 2019 +0000 |
| tree | 2dbee5b37248f1b2ad1fb78909889db4973e390f | |
| parent | 15052bcc2acecf9f975348f5cf777843d4b2c86c [diff] [blame] |
Suffix kafka topics with logical dev id or host_and_port Change-Id: Iaaaa7989ae32bff87723953297bd97dc4b6f4cd6
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):