*

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