diff --git a/schema/indexer/start.go b/schema/indexer/start.go
index 4f0c7a40f9c3..f675c2916026 100644
--- a/schema/indexer/start.go
+++ b/schema/indexer/start.go
@@ -142,7 +142,7 @@ func StartIndexing(opts IndexingOptions) (IndexingTarget, error) {
 	}
 
 	bufSize := 1024
-	if cfg.ChannelBufferSize == 0 {
+	if cfg.ChannelBufferSize != 0 {
 		bufSize = cfg.ChannelBufferSize
 	}
 	asyncOpts := appdata.AsyncListenerOptions{