diff --git a/docs/Introduction.md b/docs/Introduction.md index d515e9aa..6fedec86 100644 --- a/docs/Introduction.md +++ b/docs/Introduction.md @@ -66,10 +66,10 @@ now only support `PushConsumer` #### Interface ``` PushConsumer interface { - // Start the PullConsumer for consuming message + // Start the PushConsumer for consuming message Start() error - // Shutdown the PullConsumer, all offset of MessageQueue will be sync to broker before process exit + // Shutdown the PushConsumer, all offset of MessageQueue will be sync to broker before process exit Shutdown() error // Subscribe a topic for consuming Subscribe(topic string, selector consumer.MessageSelector, @@ -127,4 +127,4 @@ err = testAdmin.DeleteTopic( //admin.WithBrokerAddrDelete("127.0.0.1:10911"), //optional //admin.WithNameSrvAddr(nameSrvAddr), //optional ) -``` \ No newline at end of file +```