How to run multiple topics in main.go ?

[thuchoskym]

I'm a newbie Kafka-go and I have 3 or n topics. When I run them in together, only the first topic is work. the 2 topics else cannot start and receive message ? . I read docs and see:

// ReadMessage reads and return the next message from the r. The method call
// blocks until a message becomes available, or an error occurs. The program
// may also specify a context to asynchronously cancel the blocking operation.

But r called new when run NewReader(). Pls help. Thanks for all

This is code

main.go

func main() {
       con.Consumer1() /// only work
       con.Consumer2() /// can not start and cannot receive msg ?
       con.Consumer3() /// can not start and cannot receive msg ?
}

con.go

func NewReader(topic string) *kafka.Reader {
	log.Info("Start consumer", "Topic", topic)
	r := kafka.NewReader(kafka.ReaderConfig{
		Brokers:   strings.Split(config.Kafka.Brokers, ","),
		Topic:     topic,
		Partition: config.Kafka.Partition,
		MaxBytes: config.Kafka.MaxBytes,
	})
	r.SetOffset(-1)
	return r
}

func Consumer1() {
	r := c.NewReader(config.Kafka.Topic1)
	for {
		message, err := r.ReadMessage(context.Background())
		if err != nil {
			log.Error("Consumer read message", "With error", err.Error())
			break
		}
		/// Log message on here 
	}
	if err := r.Close(); err != nil {
		log.Error("Consumer error", err.Error())
	}
}

func Consumer2() {
	r := c.NewReader(config.Kafka.Topic2)
	for {
		message, err := r.ReadMessage(context.Background())
		if err != nil {
			log.Error("Consumer read message", "With error", err.Error())
			break
		}
		/// Log message on here 
	}
	if err := r.Close(); err != nil {
		log.Error("Consumer error", err.Error())
	}
}


func Consumer3() {
	r := c.NewReader(config.Kafka.Topic3)
	for {
		message, err := r.ReadMessage(context.Background())
		if err != nil {
			log.Error("Consumer read message", "With error", err.Error())
			break
		}
		/// Log message on here 
	}
	if err := r.Close(); err != nil {
		log.Error("Consumer error", err.Error())
	}
}