diff --git a/python/adapters/brcm_openomci_onu/main.py b/python/adapters/brcm_openomci_onu/main.py
index d0eadcb..54f171c 100755
--- a/python/adapters/brcm_openomci_onu/main.py
+++ b/python/adapters/brcm_openomci_onu/main.py
@@ -59,6 +59,7 @@
     accept_atomic_flow=os.environ.get('ACCEPT_ATOMIC_FLOW', True),
     etcd=os.environ.get('ETCD', 'localhost:2379'),
     core_topic=os.environ.get('CORE_TOPIC', 'rwcore'),
+    event_topic=os.environ.get('EVENT_TOPIC', 'voltha.events'),
     interface=os.environ.get('INTERFACE', get_my_primary_interface()),
     instance_id=os.environ.get('INSTANCE_ID', os.environ.get('HOSTNAME', '1')),
     kafka_adapter=os.environ.get('KAFKA_ADAPTER', '192.168.0.20:9092'),
@@ -223,6 +224,13 @@
                         default=defs['core_topic'],
                         help=_help)
 
+    _help = 'topic of events on the kafka bus'
+    parser.add_argument('-et', '--event_topic',
+                        dest='event_topic',
+                        action='store',
+                        default=defs['event_topic'],
+                        help=_help)
+
     args = parser.parse_args()
 
     # post-processing
@@ -280,6 +288,7 @@
         self.instance_id = self.args.instance_id + '_' + str(current_time)
 
         self.core_topic = args.core_topic
+        self.event_topic = args.event_topic
         self.listening_topic = args.name
         self.startup_components()
 
@@ -349,6 +358,7 @@
             self.core_proxy = CoreProxy(
                 kafka_proxy=None,
                 default_core_topic=self.core_topic,
+                default_event_topic=self.event_topic,
                 my_listening_topic=self.listening_topic)
 
             self.adapter_proxy = AdapterProxy(