#php
sasl.mechanisms = PLAIN
#java
//sasl.mechanism = java
props.put ( "ssl.endpoint.identification.algorithm","https");
props.put ( "sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required serviceName=\"kafka\" username=\"XX\" password=\"xxx\";" );
props.put ( "sasl.mechanism", "PLAIN" ); //if it is java sasl.mechanism, for php = sasl.mechanisms
sasl.mechanisms = PLAIN
#java
//sasl.mechanism = java
props.put ( "ssl.endpoint.identification.algorithm","https");
props.put ( "sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required serviceName=\"kafka\" username=\"XX\" password=\"xxx\";" );
props.put ( "sasl.mechanism", "PLAIN" ); //if it is java sasl.mechanism, for php = sasl.mechanisms
No comments:
Post a Comment