README.md

Author: ikilobyte

README-CN.md

@@ -281,6 +281,31 @@ while ($running) {
 }
 ```
 
+## TLS
+
+- 证书配置请参考[官方文档](https://pulsar.apache.org/docs/next/security-tls-transport/)
+
+- 示例
+
+```php
+$tls = new \Pulsar\TLSOptions('./cert.pem','./cert.key.pem');
+
+// CA Cert
+$tls->setTrustCertsFilePath('./ca.cart.pem');
+
+// optional
+$tls->setAllowInsecureConnection(false);
+$tls->setValidateHostname(true);
+$options->setTLS($tls);
+
+$consumer = new \Pulsar\Consumer('pulsar+ssl://localhost:6651',$options);
+//$producer = new \Pulsar\Producer('pulsar+ssl://localhost:6651',$options);
+
+// or https
+$consumer = new \Pulsar\Consumer('https://localhost:8081',$options);
+//$producer = new \Pulsar\Producer('https://localhost:8081',$options);
+```
+
 ## Schema
 
 - 目前只支持 `INT8`、`INT16`、`INT32`、`INT64`、`DOUBLE`、`STRING`、`JSON`，以下代码以 `JSON Schema` 为示例
@@ -436,6 +461,11 @@ $reader->close();
     * DELAY_SECONDS
     * SEQUENCE_ID
     * PROPERTIES
+* TLSOption (v1.3.0)
+    * __construct(string $certFilePath, string $keyFilePath)
+    * setTrustCertsFilePath()
+    * setValidateHostname()
+    * setAllowInsecureConnection()
 
 ## MessageNotFound 错误码（v1.2.1）
 

README.md

@@ -8,6 +8,7 @@
     * [Installation](#Installation)
     * [Producer](#Producer)
     * [Consumer](#Consumer)
+    * [TLS](#TLS)
     * [Schema](#Schema)
     * [Reader](#Reader)
     * [Options](#Options)
@@ -47,6 +48,7 @@ composer require ikilobyte/pulsar-client-php
 ```php
 <?php
 
+use Pulsar\Authentication\Basic;
 use Pulsar\Authentication\Jwt;
 use Pulsar\Compression\Compression;
 use Pulsar\Producer;
@@ -58,9 +60,12 @@ require_once __DIR__ . '/vendor/autoload.php';
 $options = new ProducerOptions();
 
 // If permission authentication is available
-// Only JWT authentication is currently supported
+// use JWT authentication
 $options->setAuthentication(new Jwt('token')); 
 
+// use Basic authentication
+//$options->setAuthentication(new Basic('user','password'));
+
 $options->setConnectTimeout(3);
 $options->setTopic('persistent://public/default/demo');
 $options->setCompression(Compression::ZLIB);
@@ -141,6 +146,7 @@ $producer->send('body',[
 <?php
 
 use Pulsar\Authentication\Jwt;
+use Pulsar\Authentication\Basic;
 use Pulsar\Consumer;
 use Pulsar\ConsumerOptions;
 use Pulsar\SubscriptionType;
@@ -151,9 +157,12 @@ require_once __DIR__ . '/vendor/autoload.php';
 $options = new ConsumerOptions();
 
 // If permission authentication is available
-// Only JWT authentication is currently supported
+// use JWT authentication
 $options->setAuthentication(new Jwt('token'));
 
+// use Basic authentication
+//$options->setAuthentication(new Basic('user','password'));
+
 $options->setConnectTimeout(3);
 $options->setTopic('persistent://public/default/demo');
 $options->setSubscription('logic');
@@ -282,6 +291,33 @@ while ($running) {
 }
 ```
 
+## TLS
+
+- Refer to the official [documentation](https://pulsar.apache.org/docs/next/security-tls-transport/) for certificate
+  configuration
+
+- Example
+
+```php
+$tls = new \Pulsar\TLSOptions('./cert.pem','./cert.key.pem');
+
+// CA Cert
+$tls->setTrustCertsFilePath('./ca.cart.pem');
+
+// optional
+$tls->setAllowInsecureConnection(false);
+$tls->setValidateHostname(true);
+$options->setTLS($tls);
+
+$consumer = new \Pulsar\Consumer('pulsar+ssl://localhost:6651',$options);
+//$producer = new \Pulsar\Producer('pulsar+ssl://localhost:6651',$options);
+
+
+// or https
+$consumer = new \Pulsar\Consumer('https://localhost:8081',$options);
+//$producer = new \Pulsar\Producer('https://localhost:8081',$options);
+```
+
 ## Schema
 
 - Currently only supports `INT8`、`INT16`、`INT32`、`INT64`、`DOUBLE`、`STRING`、`JSON`，The following code uses `JSON Schema`
@@ -439,6 +475,11 @@ $reader->close();
     * DELAY_SECONDS
     * SEQUENCE_ID
     * PROPERTIES
+* TLSOption (v1.3.0)
+    * __construct(string $certFilePath, string $keyFilePath)
+    * setTrustCertsFilePath()
+    * setValidateHostname()
+    * setAllowInsecureConnection()
 
 ## MessageNotFound ErrCode （v1.2.1）