Configuring kafka-fetcher to use the SASL_SSL security mode results in a failure when starting OAP.

Search before asking

• I had searched in the issues and found no similar issues.

Apache SkyWalking Component

OAP server (apache/skywalking)

What happened

\n "index": 0,\n "description": "```\nat java.base/java.lang.Thread.run(Unknown Source)\n\njava.io.IOException: Channel could not be created for socket java.nio.channels.SocketChannel[closed]\n at org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:239)\n at org.apache.kafka.common.network.Selector.connect(Selector.java:256)\n at org.apache.kafka.common.network.Selector.init(Selector.java:992)\n at org.apache.kafka.clients.NetworkClient.(NetworkClient.java:301)\n at org.apache.kafka.clients.admin.KafkaAdminClient.(KafkaAdminClient.java:1141)\n at org.apache.kafka.clients.admin.KafkaAdminClient.(KafkaAdminClient.java:1401)\n at java.base/java.lang.Thread.run(Unknown Source)\nCaused by: org.apache.kafka.common.KafkaException: Failed to configure SaslClientAuthenticator\n at org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure SaslClientAuthenticator\n at org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:338)\n ... 8 more\nCaused by: java.lang.UnsupportedOperationException: SubSubject is not supported\n at java.base/java.lang.Subject.getSubject(Unknown Source)\n at org.apache.kafka.common.security.sasl.SaslClientAuthenticator.(SaslClientAuthenticatorImpl.java:140)\n at java.security.sasl/com.sun.security.sasl.ClientFactoryImpl.createSaslClient(Unknown Source)\n at org.apache.kafka.common.security.sasl.SaslClientAuthenticator.lambda$createSaslClient$0(SaslClientAuthenticator.java:219)\n at org.apache.kafka.common.security.sasl.SaslClientAuthenticator.withoutAuthenticator(Unknown Source)\n at java.base/jdk.internal.vm.Scope$ScopeValueContainer.call(Unknown Source)\n at java.base/jdk.internal.vm.Scope.withScope(Unknown Source)\n at java.base/javax.security.auth.Subject.calls(Unknown Source)\n

What you expected to happen

It is possible to start pulling metrics and trace data from Kafak normally.

How to reproduce

The skywalking10.4.0 version encounters an error when starting up because the kafka-fetcher is set to the SASL_SSL security mode. However, this issue does not occur with the 10.1.0 version.

Anything else

No response

Are you willing to submit a pull request to fix on your own?

• Yes I am willing to submit a pull request on my own!

Code of Conduct

• I agree to follow this project's Code of Conduct