diff --git a/docs/Introduction.md b/docs/Introduction.md
index 011603a4..d515e9aa 100644
--- a/docs/Introduction.md
+++ b/docs/Introduction.md
@@ -89,8 +89,8 @@ c, err := rocketmq.NewPushConsumer(
 
 - Subscribe a topic(only support one topic now), and define your consuming function
 ```
-err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx *consumer.ConsumeMessageContext,
-    msgs []*primitive.MessageExt) (consumer.ConsumeResult, error) {
+err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context,
+		msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
     rlog.Info("Subscribe Callback", map[string]interface{}{
         "msgs": msgs,
     })