diff --git a/doc/consumer.md b/doc/consumer.md
index a11b233..c67d8c2 100644
--- a/doc/consumer.md
+++ b/doc/consumer.md
@@ -50,7 +50,9 @@ function consume(ConsumeMessage $message)
 }
 $config = new ConsumerConfig();
 $config->setBroker('127.0.0.1:9092');
-$config->setTopic('test');
+$config->setTopic('test'); // 主题名称
+$config->setGroupId('testGroup'); // 分组ID
+$config->setClientId('test'); // 客户端ID
 $config->setInterval(0.1);
 $consumer = new Consumer($config, 'consume');
 $consumer->start();
@@ -66,7 +68,9 @@ use longlang\phpkafka\Consumer\ConsumerConfig;
 
 $config = new ConsumerConfig();
 $config->setBroker('127.0.0.1:9092');
-$config->setTopic('test');
+$config->setTopic('test'); // 主题名称
+$config->setGroupId('testGroup'); // 分组ID
+$config->setClientId('test'); // 客户端ID
 $consumer = new Consumer($config);
 while(true) {
     $message = $consumer->consume();
diff --git a/examples/consumer.php b/examples/consumer.php
index 15c43fe..b6dc503 100644
--- a/examples/consumer.php
+++ b/examples/consumer.php
@@ -12,9 +12,9 @@ function consume(ConsumeMessage $message)
 }
 $config = new ConsumerConfig();
 $config->setBroker('127.0.0.1:9092');
-$config->setTopic('test');
-$config->setGroupId('testGroup');
-$config->setClientId('test');
+$config->setTopic('test'); // 主题名称
+$config->setGroupId('testGroup'); // 分组ID
+$config->setClientId('test'); // 客户端ID
 $config->setInterval(0.1);
 $consumer = new Consumer($config, 'consume');
 $consumer->start();
diff --git a/examples/consumer_custom.php b/examples/consumer_custom.php
index d1c1f00..13c33a4 100644
--- a/examples/consumer_custom.php
+++ b/examples/consumer_custom.php
@@ -7,17 +7,18 @@
 
 $config = new ConsumerConfig();
 $config->setBroker('127.0.0.1:9092');
-$config->setTopic('test');
-$config->setGroupId('testGroup');
-$config->setClientId('test');
+$config->setTopic('test'); // 主题名称
+$config->setGroupId('testGroup'); // 分组ID
+$config->setClientId('test'); // 客户端ID
 $consumer = new Consumer($config);
 while (true) {
     $message = $consumer->consume();
     if ($message) {
         var_dump($message->getKey() . ':' . $message->getValue());
         $consumer->ack($message->getPartition()); // ack
+    } else {
+        usleep(10000);
     }
-    sleep(1);
 }
 
 return;
diff --git a/examples/producer.php b/examples/producer.php
index 960fe66..149dafc 100644
--- a/examples/producer.php
+++ b/examples/producer.php
@@ -14,7 +14,7 @@
 while (true) {
     $producer->send('test', (string) microtime(true), uniqid('', true));
     var_dump(++$i);
-    sleep(3);
+    sleep(1);
 }
 
 return;