kingnet

提交代码

目前就是下载的example里面的 本地使用 kafka-console-producer.sh 访问 配置 bootstrap.servers=ip:9093 security.protocol=SSL ssl.truststore.location=/xxxx/kafka.truststore ssl.truststore.password=passwd ssl.keystore.password=passwd ssl.keystore.location=/xxxx/kafka.keystore 是可以连上的； 现在本地的ssl包括 ca-cert ca-cert.srl ca-key kafka.keystore kafka.truststore ================ 通过php 的代码 这块的参数不是很了解； 看了配置说明还是 迷糊，望指导 $config = ProducerConfig::getInstance(); $config->setMetadataRefreshIntervalMs(10000); $config->setMetadataBrokerList('ip地址:9093'); $config->setBrokerVersion('1.0.0');...