KsqlClientException：从服务器收到 401 响应：未经授权。错误代码：40100

Question

正在尝试连接到 Confluent 托管的 KSQL 数据库。

    String username = API_KEY;      
    String password = API_SECRET;
    
    String CONFLUENT_CLOUD_HOST = "pksqlc-xxxxx.us-east-2.aws.confluent.cloud";
    
    ClientOptions options = ClientOptions.create()
            .setHost(CONFLUENT_CLOUD_HOST)
            .setPort(443)
            .setBasicAuthCredentials(username, password)
            .setUseTls(true)
            .setUseAlpn(true)
            ;
    Client client = Client.create(options);

    List<StreamInfo> streams = client.listStreams().get();

我在 client.listStreams().get() 期间遇到异常：

Exception in thread "main" java.util.concurrent.ExecutionException: io.confluent.ksql.api.client.exception.KsqlClientException: Received 401 response from server: Unauthorized. Error code: 40100
   at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
   at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)

我在这里错过了什么？

Answer 1

您是否检查了您的 Confluent Cloud 集群上的 API_KEY/API_SECRET 以查看它是否被授予访问 KSQLDB 的权限？

KsqlClientException：从服务器收到 401 响应：未经授权。错误代码：40100

KsqlClientException: Received 401 response from server: Unauthorized. Error code: 40100

java

apache-kafka

confluent-platform

ksqldb