[
https://issues.apache.org/jira/browse/KAFKA-9873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084021#comment-17084021
]
zhang chao edited comment on KAFKA-9873 at 4/15/20, 12:06 PM:
--------------------------------------------------------------
{code:java}
// Some comments here
"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-2"
#68 prio=5 os_prio=0 tid=0x00007f38205a0000 nid=0x62c2 runnable
[0x00007f36142f6000]"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-2"
#68 prio=5 os_prio=0 tid=0x00007f38205a0000 nid=0x62c2 runnable
[0x00007f36142f6000] java.lang.Thread.State: RUNNABLE at
java.net.Inet6AddressImpl.getHostByAddr(Native Method) at
java.net.InetAddress$2.getHostByAddr(InetAddress.java:933) at
java.net.InetAddress.getHostFromNameService(InetAddress.java:618) at
java.net.InetAddress.getHostName(InetAddress.java:560) at
java.net.InetAddress.getHostName(InetAddress.java:532) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.lambda$createSaslServer$0(SaslServerAuthenticator.java:195)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$$Lambda$779/1182531626.run(Unknown
Source) at java.security.AccessController.doPrivileged(Native Method) at
javax.security.auth.Subject.doAs(Subject.java:422) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.createSaslServer(SaslServerAuthenticator.java:194)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.handleKafkaRequest(SaslServerAuthenticator.java:534)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:285)
at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:173)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483) at
kafka.network.Processor.poll(SocketServer.scala:830) at
kafka.network.Processor.run(SocketServer.scala:730) at
java.lang.Thread.run(Thread.java:748)
"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-1"
#67 prio=5 os_prio=0 tid=0x00007f382059e000 nid=0x62c1 runnable
[0x00007f36143f7000] java.lang.Thread.State: RUNNABLE at
java.net.Inet6AddressImpl.getHostByAddr(Native Method) at
java.net.InetAddress$2.getHostByAddr(InetAddress.java:933) at
java.net.InetAddress.getHostFromNameService(InetAddress.java:618) at
java.net.InetAddress.getHostName(InetAddress.java:560) at
java.net.InetAddress.getHostName(InetAddress.java:532) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.lambda$createSaslServer$0(SaslServerAuthenticator.java:195)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$$Lambda$779/1182531626.run(Unknown
Source) at java.security.AccessController.doPrivileged(Native Method) at
javax.security.auth.Subject.doAs(Subject.java:422) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.createSaslServer(SaslServerAuthenticator.java:194)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.handleKafkaRequest(SaslServerAuthenticator.java:534)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:285)
at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:173)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483) at
kafka.network.Processor.poll(SocketServer.scala:830) at
kafka.network.Processor.run(SocketServer.scala:730) at
java.lang.Thread.run(Thread.java:748)
"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-0"
#66 prio=5 os_prio=0 tid=0x00007f38214ed800 nid=0x62c0 runnable
[0x00007f36144f8000] java.lang.Thread.State: RUNNABLE at
java.net.Inet6AddressImpl.getHostByAddr(Native Method) at
java.net.InetAddress$2.getHostByAddr(InetAddress.java:933) at
java.net.InetAddress.getHostFromNameService(InetAddress.java:618) at
java.net.InetAddress.getHostName(InetAddress.java:560) at
java.net.InetAddress.getHostName(InetAddress.java:532) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.lambda$createSaslServer$0(SaslServerAuthenticator.java:195)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$$Lambda$779/1182531626.run(Unknown
Source) at java.security.AccessController.doPrivileged(Native Method) at
javax.security.auth.Subject.doAs(Subject.java:422) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.createSaslServer(SaslServerAuthenticator.java:194)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.handleKafkaRequest(SaslServerAuthenticator.java:534)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:285)
at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:173)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483) at
kafka.network.Processor.poll(SocketServer.scala:830) at
kafka.network.Processor.run(SocketServer.scala:730) at
java.lang.Thread.run(Thread.java:748){code}
was (Author: zchzx30):
{code:java}
// Some comments here
"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-2"
#68 prio=5 os_prio=0 tid=0x00007f38205a0000 nid=0x62c2 runnable
[0x00007f36142f6000]"data-plane-kafka-network-thread-1002-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-2"
#68 prio=5 os_prio=0 tid=0x00007f38205a0000 nid=0x62c2 runnable
[0x00007f36142f6000] java.lang.Thread.State: RUNNABLE at
java.net.Inet6AddressImpl.getHostByAddr(Native Method) at
java.net.InetAddress$2.getHostByAddr(InetAddress.java:933) at
java.net.InetAddress.getHostFromNameService(InetAddress.java:618) at
java.net.InetAddress.getHostName(InetAddress.java:560) at
java.net.InetAddress.getHostName(InetAddress.java:532) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.lambda$createSaslServer$0(SaslServerAuthenticator.java:195)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$$Lambda$779/1182531626.run(Unknown
Source) at java.security.AccessController.doPrivileged(Native Method) at
javax.security.auth.Subject.doAs(Subject.java:422) at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.createSaslServer(SaslServerAuthenticator.java:194)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.handleKafkaRequest(SaslServerAuthenticator.java:534)
at
org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:285)
at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:173)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483) at
kafka.network.Processor.poll(SocketServer.scala:830) at
kafka.network.Processor.run(SocketServer.scala:730) at
java.lang.Thread.run(Thread.java:748)
{code}
> DNS故障时服务处理线程hang住
> -----------------
>
> Key: KAFKA-9873
> URL: https://issues.apache.org/jira/browse/KAFKA-9873
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 2.4.1
> Reporter: zhang chao
> Priority: Major
> Labels: DNS, acl, dns
> Attachments: kast.log
>
>
> 如附件所示，开启安全认证后，acl鉴权失败，导致所有处理线程无法工作
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
