正在尝试连接到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)

我错过了什么？