RivenSun2 commented on PR #12539:
URL: https://github.com/apache/kafka/pull/12539#issuecomment-1220325922
The two exceptions thrown in the
`SaslClientAuthenticator.createSaslClient()` method, whether the exception
information can be distinguished by sitting down.
Because when the JDK prints the stack, there will be an operation like
"common frames omitted", and sometimes I can't tell which line of code the
exception is thrown from.
`SaslServerAuthenticator.createSaslServer()` method is the same as above.
```
2022-08-18 15:09:55.080[][WARN][kafka-producer-network-thread |
producer-2][NetworkClient][Producer clientId=producer-2] Bootstrap broker
*.*.*.*:9889 (id: -3 rack: null) disconnected
2022-08-18 15:09:55.081[][WARN][asyncmq-11-topic testTopic | group
testGroup-pull-0][NetworkClient][Consumer
clientId=consumer-testTopic_testGroup-1, groupId=testGroup] Error connecting to
node *.*.*.*:9889 (id: -1 rack: null)
java.io.IOException: Channel could not be created for socket
java.nio.channels.SocketChannel[closed]
at
org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:348)
at
org.apache.kafka.common.network.Selector.registerChannel(Selector.java:329)
at
org.apache.kafka.common.network.Selector.connect(Selector.java:256)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:981)
at
org.apache.kafka.clients.NetworkClient.access$600(NetworkClient.java:73)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1152)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1040)
at
org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:164)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:258)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:483)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1262)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1231)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
at
us.zoom.mq.client.impl.kafka.ConsumerClient.poll(ConsumerClient.java:192)
at us.zoom.mq.client.worker.PullWorker.run(PullWorker.java:149)
at us.zoom.commons.threadpool.ZoomRunnable.run(ZoomRunnable.java:61)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Caused by: org.apache.kafka.common.KafkaException:
org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure
SaslClientAuthenticator
at
org.apache.kafka.common.network.SaslChannelBuilder.buildChannel(SaslChannelBuilder.java:240)
at
org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:338)
... 22 common frames omitted
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException:
Failed to configure SaslClientAuthenticator
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException:
Failed to create SaslClient with mechanism PLAIN
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
