diff --git a/flow/grpc_producer.go b/flow/grpc_producer.go
index cd895f0..c078ef5 100644
--- a/flow/grpc_producer.go
+++ b/flow/grpc_producer.go
@@ -59,6 +59,7 @@ func NewProducerService(params map[string]interface{}) ProducerService {
 		kafkaMaxRetry:          params["kafkaMaxRetry"].(int),
 		kafkaRetryInterval:     params["kafkaRetryInterval"].(int),
 		newEventTopic:          params["newEventTopic"].(string),
+		grpcMaxRecvMsgSize:     params["grpcMaxRecvMsgSize"].(int),
 	}
 }