我的目的:测试KoP对PLAIN认证的支持度。
机器配置:
pulsar2.8.3+Kop2.8.3.5
broker配置文件:
按照Client authentication using tokens based on JSON Web Tokens | Apache Pulsar 进行配置
但brokerClientTrustCertsFilePath=/path/my-ca/certs/ca.cert.pem
未配置
报错信息:
16:11:25.084 [main] ERROR org.apache.pulsar.PulsarBrokerStarter - Failed to start pulsar service.
org.apache.pulsar.broker.PulsarServerException: java.lang.IllegalStateException: org.apache.pulsar.broker.PulsarServerException: java.lang.IllegalArgumentException: Web service address was not set properly , isBrokerClientTlsEnabled: true, webServiceAddressTls: null, webServiceAddress: http://wy1:8080
at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:789) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.PulsarBrokerStarter$BrokerStarter.start(PulsarBrokerStarter.java:259) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.PulsarBrokerStarter.main(PulsarBrokerStarter.java:331) [org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
Caused by: java.lang.IllegalStateException: org.apache.pulsar.broker.PulsarServerException: java.lang.IllegalArgumentException: Web service address was not set properly , isBrokerClientTlsEnabled: true, webServiceAddressTls: null, webServiceAddress: http://wy1:8080
at io.streamnative.pulsar.handlers.kop.KafkaProtocolHandler.start(KafkaProtocolHandler.java:211) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoader.start(ProtocolHandlerWithClassLoader.java:76) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.lambda$start$4(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at java.lang.Iterable.forEach(Iterable.java:75) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.start(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:753) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
... 2 more
Caused by: org.apache.pulsar.broker.PulsarServerException: java.lang.IllegalArgumentException: Web service address was not set properly , isBrokerClientTlsEnabled: true, webServiceAddressTls: null, webServiceAddress: http://wy1:8080
at org.apache.pulsar.broker.PulsarService.getAdminClient(PulsarService.java:1419) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at io.streamnative.pulsar.handlers.kop.KafkaProtocolHandler.start(KafkaProtocolHandler.java:207) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoader.start(ProtocolHandlerWithClassLoader.java:76) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.lambda$start$4(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at java.lang.Iterable.forEach(Iterable.java:75) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.start(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:753) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
... 2 more
Caused by: java.lang.IllegalArgumentException: Web service address was not set properly , isBrokerClientTlsEnabled: true, webServiceAddressTls: null, webServiceAddress: http://wy1:8080
at org.apache.pulsar.broker.PulsarService.getAdminClient(PulsarService.java:1391) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at io.streamnative.pulsar.handlers.kop.KafkaProtocolHandler.start(KafkaProtocolHandler.java:207) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoader.start(ProtocolHandlerWithClassLoader.java:76) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.lambda$start$4(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at java.lang.Iterable.forEach(Iterable.java:75) ~[?:?]
at org.apache.pulsar.broker.protocol.ProtocolHandlers.start(ProtocolHandlers.java:142) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:753) ~[org.apache.pulsar-pulsar-broker-2.8.3.jar:2.8.3]
... 2 more
请问是啥原因呢?