fix channel buffer

sundy-li · Jul 29, 2017 · 9b18747 · 9b18747
1 parent 1105bb0
commit 9b18747
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/monitor/client.go b/monitor/client.go
@@ -94,8 +94,8 @@ func NewKafkaClient(cfg *config.Config, cluster string) (*KafkaClient, error) {
 		cfg:            cfg,
 		client:         sclient,
 		masterConsumer: master,
-		messageChannel: make(chan *sarama.ConsumerMessage),
-		errorChannel:   make(chan *sarama.ConsumerError),
+		messageChannel: make(chan *sarama.ConsumerMessage, 1000),
+		errorChannel:   make(chan *sarama.ConsumerError, 1000),
 		wgFanIn:        sync.WaitGroup{},
 		wgProcessor:    sync.WaitGroup{},
 		topicMap:       make(map[string]int),