Which one is faster and better for consuming many topics?

[wuttichai3113]

Should i use for high performance?

func main() {
	// ... rest of main function
	topics := []string{"aa", "bb", "cc"}
	for _, topic := range k.topics {
		go consumeTopic(topic)
	}
	// ... rest of main function
}

func consumeTopic(topic string) {
	reader := kafka.NewReader(kafka.ReaderConfig{
		Brokers:  k.brokers,
		GroupID:  "group1",
		Topic:    topic,
		MinBytes: 10e3, // 10KB
		MaxBytes: 10e6, // 10MB
	})
	defer reader.Close()

	// ... rest of consumeTopic function
}

Or

func main() {
	// ... rest of main function
	topics := []string{"aa", "bb", "cc"}
	consume(topics)	
	// ... rest of main function
}

func consume(topics []string) {
	reader := kafka.NewReader(kafka.ReaderConfig{
		Brokers:  k.brokers,
		GroupID:  "group1",
		GroupTopics: topics,
		MinBytes: 10e3, // 10KB
		MaxBytes: 10e6, // 10MB
	})
	defer reader.Close()

	// ... rest of consumeTopic function
}

[thuchoskym]

I had problem when using many topics guy :)