diff --git a/cmd/ofagent/config.go b/cmd/ofagent/config.go
index ba8b710..a929077 100644
--- a/cmd/ofagent/config.go
+++ b/cmd/ofagent/config.go
@@ -38,6 +38,9 @@
 	KVStoreTimeout            time.Duration
 	KVStoreAddress            string
 	InstanceID                string
+	TraceEnabled              bool
+	TraceAgentAddress         string
+	LogCorrelationEnabled     bool
 }
 
 type multiFlag []string
@@ -124,6 +127,19 @@
 
 	flag.StringVar(&(config.LogLevel), "log_level", "WARN", "Log level")
 
+	flag.BoolVar(&(config.TraceEnabled),
+		"trace_enabled",
+		false,
+		"Whether to send logs to tracing agent?")
+	flag.StringVar(&(config.TraceAgentAddress),
+		"trace_agent_address",
+		"127.0.0.1:6831",
+		"The address of tracing agent to which span info should be sent.")
+	flag.BoolVar(&(config.LogCorrelationEnabled),
+		"log_correlation_enabled",
+		true,
+		"Whether to enrich log statements with fields denoting operation being executed for achieving correlation?")
+
 	containerName := getContainerInfo()
 	if len(containerName) > 0 {
 		config.InstanceID = containerName
diff --git a/cmd/ofagent/main.go b/cmd/ofagent/main.go
index 911d99e..1dd05fb 100644
--- a/cmd/ofagent/main.go
+++ b/cmd/ofagent/main.go
@@ -132,6 +132,13 @@
 		logger.Warnw(ctx, "unable-to-create-kvstore-client", log.Fields{"error": err})
 	}
 
+	closer, err := log.InitTracingAndLogCorrelation(config.TraceEnabled, config.TraceAgentAddress, config.LogCorrelationEnabled)
+	if err != nil {
+		logger.Warnw(ctx, "unable-to-initialize-tracing-and-log-correlation-module", log.Fields{"error": err})
+	} else {
+		defer closer.Close()
+	}
+
 	ofa, err := ofagent.NewOFAgent(ctx, &ofagent.OFAgent{
 		OFControllerEndPoints:     config.OFControllerEndPoints,
 		VolthaApiEndPoint:         config.VolthaApiEndPoint,