java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.SaslAuthenticationException: Role cannot be empty.

[KamenRiderKuuga]

After I configure the kop and send message via Java Kafka client according to the example, this exception was thrown: org.apache.kafka.common.errors.SaslAuthenticationException: Role cannot be empty.

I have checked all configurations with reference to the documentation: https://github.com/streamnative/kop/blob/master/docs/security.md#plain

This is usually related to what configuration, thank you!

The client code:

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "pulsar:" + 9092);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
String jaasTemplate = "org.apache.kafka.common.security.plain.PlainLoginModule "
        + "required username=\"%s\" password=\"%s\";";
String jaasCfg = String.format(jaasTemplate, "public", "token:" + "token value");
props.put("sasl.jaas.config", jaasCfg);
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");
var producer = new KafkaProducer<>(props);

[KamenRiderKuuga]

Resolved in #1929