From a559ad0160b7db40a848a9456c72130f17f39572 Mon Sep 17 00:00:00 2001 From: slaventius Date: Tue, 31 Jan 2023 20:16:19 +0300 Subject: [PATCH] * --- cmd/main.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/cmd/main.go b/cmd/main.go index 91e7a5b..2d4dce3 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -10,14 +10,13 @@ import ( func main() { ctx := context.Background() - config := kafka.ReaderConfig{ + consumer := kafka.NewReader(kafka.ReaderConfig{ Brokers: []string{"localhost:9092"}, Topic: "topic-A", Partition: 0, MinBytes: 10e3, // 10KB MaxBytes: 10e6, // 10MB - } - consumer := kafka.NewReader(config) + }) defer consumer.Close() //