我有一个spring服务正在运行，我可以确认客户端对象已经创建，但是我在日志中没有看到任何指示查询已经启动或创建的内容。我也没有看到日志中的错误。因此，我想就如何调试这个和什么问题可能是建议。我从命令行运行相同的查询，它运行并捕获事件。但是java客户机没有响应，也没有print语句指示查询被创建。为什么没有开火？

public void initKSQL(){

    ClientOptions options = ClientOptions.create()
        .setHost(KSQLDB_SERVER_HOST)
        .setPort(KSQLDB_SERVER_HOST_PORT);
    ksqlClient = Client.create(options);

    ksqlClient.streamQuery("SELECT * FROM MY_STREAM EMIT CHANGES;")
        .thenAccept(streamedQueryResult -> {
            System.out.println("Query has started. Query ID: " + streamedQueryResult.queryID());

            RowSubscriber subscriber = new RowSubscriber();
            streamedQueryResult.subscribe(subscriber);
        }).exceptionally(e -> {
        log.debug("Request failed: " + e);
        return null;
    });
    log.debug("got client "+ksqlClient);

    // Send requests with the client by following the other examples

    // Terminate any open connections and close the client
}