Sun Xiangtian

以下是node代码，在java中是可以通过``` PulsarClient client = PulsarClient.builder().serviceUrl(brokerServerUrl).allowTlsInsecureConnection(true) .authentication(new IoTAuthentication(iotAccessId, iotSecretKey)).build(); Consumer consumer = client.newConsumer(Schema.STRING).topic(String.format("%s/iot/event", iotAccessId)) .subscriptionName(subscriptionName).subscriptionType(SubscriptionType.Failover) .autoUpdatePartitions(Boolean.FALSE).subscribe(); ``` 这种方式来跳过ssl证书的，在下面node中我也加入了tlsAllowInsecureConnection: true, tlsValidateHostname: false,这两个参数但是无法连接到服务 `const Pulsar = require('pulsar-client'); const crypto = require('crypto'); const iotAccessId...

欠薪,老板画大饼,管理层傻逼