Skip to content

Instantly share code, notes, and snippets.

@boscomonkey
Created January 10, 2025 22:58
Show Gist options
  • Save boscomonkey/64262b211eba86e97cc060a372912fce to your computer and use it in GitHub Desktop.
Save boscomonkey/64262b211eba86e97cc060a372912fce to your computer and use it in GitHub Desktop.
Partial stack trace from calling "kafka-acls" on a Confluent Cloud Kafka instance
[2025-01-10 14:28:56,512] WARN [AdminClient clientId=ccloud-java-client-fe690841-bdf7-4231-8340-f78dd6a8cad9] Error connecting to node pkc-rgm37.us-west-2.aws.confluent.cloud:9092 (id: -1 rack: null) (org.apache.kafka.clients.NetworkClient)
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:368)
at org.apache.kafka.common.network.Selector.registerChannel(Selector.java:345)
at org.apache.kafka.common.network.Selector.connect(Selector.java:272)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:1077)
at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:321)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.sendEligibleCalls(KafkaAdminClient.java:1270)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1530)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1473)
at java.base/java.lang.Thread.run(Thread.java:1575)
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:251)
at org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:356)
... 8 more
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure SaslClientAuthenticator
Caused by: java.lang.UnsupportedOperationException: getSubject is supported only if a security manager is allowed
at java.base/javax.security.auth.Subject.getSubject(Subject.java:347)
at org.apache.kafka.common.security.authenticator.SaslClientCallbackHandler.handle(SaslClientCallbackHandler.java:58)
at java.security.sasl/com.sun.security.sasl.ClientFactoryImpl.getUserInfo(ClientFactoryImpl.java:138)
at java.security.sasl/com.sun.security.sasl.ClientFactoryImpl.createSaslClient(ClientFactoryImpl.java:96)
at java.security.sasl/javax.security.sasl.Sasl.createSaslClient(Sasl.java:434)
at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.lambda$createSaslClient$0(SaslClientAuthenticator.java:222)
at java.base/jdk.internal.vm.ScopedValueContainer.callWithoutScope(ScopedValueContainer.java:162)
at java.base/jdk.internal.vm.ScopedValueContainer.call(ScopedValueContainer.java:147)
at java.base/java.lang.ScopedValue$Carrier.call(ScopedValue.java:420)
at java.base/java.lang.ScopedValue.callWhere(ScopedValue.java:568)
at java.base/javax.security.auth.Subject.callAs(Subject.java:439)
at java.base/javax.security.auth.Subject.doAs(Subject.java:614)
at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.createSaslClient(SaslClientAuthenticator.java:218)
at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.<init>(SaslClientAuthenticator.java:209)
at org.apache.kafka.common.network.SaslChannelBuilder.buildClientAuthenticator(SaslChannelBuilder.java:297)
at org.apache.kafka.common.network.SaslChannelBuilder.lambda$buildChannel$1(SaslChannelBuilder.java:237)
at org.apache.kafka.common.network.KafkaChannel.<init>(KafkaChannel.java:143)
at org.apache.kafka.common.network.SaslChannelBuilder.buildChannel(SaslChannelBuilder.java:245)
at org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:356)
at org.apache.kafka.common.network.Selector.registerChannel(Selector.java:345)
at org.apache.kafka.common.network.Selector.connect(Selector.java:272)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:1077)
at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:321)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.sendEligibleCalls(KafkaAdminClient.java:1270)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1530)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1473)
at java.base/java.lang.Thread.run(Thread.java:1575)
Error while executing ACL command: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeAcls
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeAcls
at java.base/java.util.concurrent.CompletableFuture.wrapInExecutionException(CompletableFuture.java:345)
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:440)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2117)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at kafka.admin.AclCommand$AdminClientService.getAcls(AclCommand.scala:177)
at kafka.admin.AclCommand$AdminClientService.listAcls(AclCommand.scala:146)
at kafka.admin.AclCommand$AdminClientService.$anonfun$listAcls$1(AclCommand.scala:139)
at kafka.admin.AclCommand$AdminClientService.listAcls(AclCommand.scala:138)
at kafka.admin.AclCommand$.main(AclCommand.scala:78)
at kafka.admin.AclCommand.main(AclCommand.scala)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeAcls
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment