| 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_indications.py b/voltha/adapters/openolt/openolt_indications.py index 54415ba..4873984 100644 --- a/voltha/adapters/openolt/openolt_indications.py +++ b/voltha/adapters/openolt/openolt_indications.py
@@ -42,7 +42,10 @@ def indications_thread(self): self.log.debug('openolt indications thread starting') - KConsumer(self.indications_process, "openolt.ind") + + KConsumer(self.indications_process, + 'openolt.ind-{}'.format( + self.device.host_and_port.split(':')[0])) def indications_process(self, topic, msg):