commit 4750d3c90d5e18d6a4e16fa9d2fb6a899620bd7a
author Elia Battiston <elia.battiston@radisys.com> Thu Jul 14 13:24:56 2022 +0000
committer Elia Battiston <elia.battiston@radisys.com> Fri Jul 15 08:03:28 2022 +0000
tree 168401a999207c387d479980ab95060abd0426a1
parent d10fe3c0309789ad299abefbc12622cad88400b8

Add NETCONF notification for ONU activation and Kafka client to receive events, update dependencies

Change-Id: I5f768fa8077ef7c64e00a534744ca47492344935

internal/config/config.go

diff --git a/internal/config/config.go b/internal/config/config.go
index d3be1fc..ff7f36f 100644
--- a/internal/config/config.go
+++ b/internal/config/config.go
@@ -36,6 +36,7 @@
 	OnosUser              string
 	OnosPassword          string
 	SchemaMountFilePath   string
+	KafkaClusterAddress   string
 }
 
 // LoadConfig loads the BBF adapter configuration through
@@ -57,6 +58,7 @@
 	flag.StringVar(&conf.OnosUser, "onos_user", conf.OnosUser, "Username for ONOS REST APIs")
 	flag.StringVar(&conf.OnosPassword, "onos_pass", conf.OnosPassword, "Password for ONOS REST APIs")
 	flag.StringVar(&conf.SchemaMountFilePath, "schema_mount_path", conf.SchemaMountFilePath, "Path to the XML file that defines schema-mounts for libyang")
+	flag.StringVar(&conf.KafkaClusterAddress, "kafka_cluster_address", conf.KafkaClusterAddress, "Kafka cluster messaging address")
 
 	flag.Parse()
 
@@ -80,5 +82,6 @@
 		OnosUser:              "onos",
 		OnosPassword:          "rocks",
 		SchemaMountFilePath:   "/schema-mount.xml",
+		KafkaClusterAddress:   "127.0.0.1:9092",
 	}
 }