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() //