grafana
diff --git a/‎publish/kafka/publish.go
+2-2 b/‎publish/kafka/publish.go
+2-2
diff --git a/‎publish/kafka/schemas.go
-13 b/‎publish/kafka/schemas.go
-13
@@ -197,11 +197,11 @@ func New(brokers []string, autoInterval bool) *mtPublisher {
 	}
 
 	if autoInterval {
-		schemas, err := getSchemas(schemasConf)
+		schemas, err := conf.ReadSchemas(schemasConf)
 		if err != nil {
 			log.Fatalf("failed to load schemas config. %s", err)
 		}
-		mp.schemas = schemas
+		mp.schemas = &schemas
 	}
 
 	// We are looking for strong consistency semantics.
Original file line number	Diff line number	Diff line change
`@@ -197,11 +197,11 @@ func New(brokers []string, autoInterval bool) *mtPublisher {`
`197`	`197`	`}`
`198`	`198`
`199`	`199`	`if autoInterval {`
`200`		`- schemas, err := getSchemas(schemasConf)`
	`200`	`+ schemas, err := conf.ReadSchemas(schemasConf)`
`201`	`201`	`if err != nil {`
`202`	`202`	`log.Fatalf("failed to load schemas config. %s", err)`
`203`	`203`	`}`
`204`		`- mp.schemas = schemas`
	`204`	`+ mp.schemas = &schemas`
`205`	`205`	`}`
`206`	`206`
`207`	`207`	`// We are looking for strong consistency semantics.`