ksqldb java客户端未获得查询结果

tp5buhyn  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(274)

我有一个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
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题