Update doc and examples

swoole · Nov 24, 2020 · 97b1433 · 97b1433
1 parent ab74400
commit 97b1433
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 10 deletions.
diff --git 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
@@ -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
@@ -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
@@ -14,7 +14,7 @@
 while (true) {
     $producer->send('test', (string) microtime(true), uniqid('', true));
     var_dump(++$i);
-    sleep(3);
+    sleep(1);
 }
 
 return;