[
https://issues.apache.org/jira/browse/KAFKA-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084122#comment-17084122
]
para edited comment on KAFKA-9874 at 4/15/20, 2:39 PM:
-------------------------------------------------------
{code:java}
"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)
"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)
{code}
was (Author: zchzx):
{code:java}
"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)
"Controller-1002-to-broker-1002-send-thread" #65 prio=5 os_prio=0
tid=0x00007f378004c800 nid=0x62bf runnable [0x00007f36145fa000]
java.lang.Thread.State: RUNNABLE at
sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked
<0x00000000fa926138> (a sun.nio.ch.Util$3) - locked <0x00000000fa926128> (a
java.util.Collections$UnmodifiableSet) - locked <0x00000000fa926148> (a
sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.apache.kafka.common.network.Selector.select(Selector.java:794)
at org.apache.kafka.common.network.Selector.poll(Selector.java:467)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:535)
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:74)
at
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:282)
at
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:236)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
{code}
> broker can not work when use dns fault
> --------------------------------------
>
> Key: KAFKA-9874
> URL: https://issues.apache.org/jira/browse/KAFKA-9874
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 2.4.1
> Reporter: para
> Priority: Critical
> Labels: acl, dns
> Attachments: kast.log
>
>
> in 2.3.1 we authenticate using sasl blocked when the dns service is
> fault，caused by java native func getHostByAddr.
> but the hostname was never used, can use the default name instead of it
>
> h3.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
