From acf44b68569f6615d373f05f92671afecb296af8 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Wed, 7 Feb 2024 14:02:22 +0100 Subject: wip --- util/util.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) (limited to 'util') diff --git a/util/util.go b/util/util.go index 57c8246..d56f662 100644 --- a/util/util.go +++ b/util/util.go @@ -6,11 +6,10 @@ import ( "os" "strings" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func ReadConfig(configFile string) kafka.ConfigMap { - m := make(map[string]kafka.ConfigValue) file, err := os.Open(configFile) @@ -39,5 +38,4 @@ func ReadConfig(configFile string) kafka.ConfigMap { } return m - } -- cgit v1.2.3