diff options
| author | Trygve Laugstøl <trygvis@inamo.no> | 2024-02-07 14:02:22 +0100 |
|---|---|---|
| committer | Trygve Laugstøl <trygvis@inamo.no> | 2024-02-07 14:02:22 +0100 |
| commit | acf44b68569f6615d373f05f92671afecb296af8 (patch) | |
| tree | 337b49bb93ed8cc08096e803065c72f3e87f9642 /util | |
| parent | c4d37d593262f8ff0053693513d1a5e397ff2b5d (diff) | |
| download | kafka-sandbox-acf44b68569f6615d373f05f92671afecb296af8.tar.gz kafka-sandbox-acf44b68569f6615d373f05f92671afecb296af8.tar.bz2 kafka-sandbox-acf44b68569f6615d373f05f92671afecb296af8.tar.xz kafka-sandbox-acf44b68569f6615d373f05f92671afecb296af8.zip | |
wip
Diffstat (limited to 'util')
| -rw-r--r-- | util/util.go | 4 |
1 files changed, 1 insertions, 3 deletions
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 - } |