Skip to content
This repository was archived by the owner on Oct 7, 2022. It is now read-only.

Commit fb3dc2f

Browse files
author
João Assunção
committed
fix(injector): adds checking for error returned by log function
1 parent 83453b7 commit fb3dc2f

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

cmd/injector.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,10 @@ func main() {
3333
metrics.Register()
3434
schemaRegistry, err := schema_registry.NewSchemaRegistry(os.Getenv("SCHEMA_REGISTRY_URL"))
3535
if err != nil {
36-
level.Error(logger).Log("err", err, "message", "failed to create schema registry client")
36+
err = level.Error(logger).Log("err", err, "message", "failed to create schema registry client")
37+
if err != nil {
38+
panic(err)
39+
}
3740
}
3841

3942
kafkaConfig := &kafka.Config{

0 commit comments

Comments
 (0)