在kafka中,有没有任何方法可以让我们看到流/表的查询正在运行?

uxhixvfz  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(392)

我想看到在kafka中为我的流/表运行的查询。

Create stream foo as select * from bar where distuinguisher='xxx';

 Message                    
----------------------------
 Stream created and running 
----------------------------

一旦有人创建了流/表,我只能查询流/表。有什么方法可以让我看到流背后的逻辑或完整查询吗。

pxq42qpu

pxq42qpu1#

DESCRIBE EXTENDED 我会给你这个信息。你也可以使用 SHOW QUERIES 查看正在运行的所有查询。
例如:

ksql> DESCRIBE EXTENDED FOO;

Name                 : FOO
Type                 : STREAM
Key field            :
Key format           : STRING
Timestamp field      : Not set - using <ROWTIME>
Value format         : JSON
Kafka topic          : FOO (partitions: 1, replication: 1)

 Field   | Type
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- ROWTIME | BIGINT           (system)
 ROWKEY  | VARCHAR(STRING)  (system)
 LOGGER  | VARCHAR(STRING)
 LEVEL   | VARCHAR(STRING)
 TIME    | BIGINT
 MESSAGE | STRUCT<TYPE INTEGER, DESERIALIZATIONERROR STRUCT<ERRORMESSAGE VARCHAR(STRING), RECORDB64 VARCHAR(STRING), CAUSE ARRAY<VARCHAR(STRING)>>, RECORDPROCESSINGERROR STRUCT<ERRORMESSAGE VARCHAR(STRING), RECORD VARCHAR(STRING), CAUSE ARRAY<VARCHAR(STRING)>>, PRODUCTIONERROR STRUCT<ERRORMESSAGE VARCHAR(STRING)>>
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Queries that write from this STREAM
-----------------------------------
CSAS_FOO_1 : CREATE STREAM FOO WITH (KAFKA_TOPIC='FOO', PARTITIONS=1, REPLICAS=1) AS SELECT *
FROM KSQL_PROCESSING_LOG KSQL_PROCESSING_LOG
EMIT CHANGES;

For query topology and execution plan please run: EXPLAIN <QueryId>

Local runtime statistics
------------------------

(Statistics of the local KSQL server interaction with the Kafka topic FOO)
ksql>
ksql> SHOW QUERIES;

 Query ID   | Kafka Topic | Query String
-------------------------------------------------------------------------------------------------------------
 CSAS_FOO_1 | FOO         | CREATE STREAM FOO WITH (KAFKA_TOPIC='FOO', PARTITIONS=1, REPLICAS=1) AS SELECT *
FROM KSQL_PROCESSING_LOG KSQL_PROCESSING_LOG
EMIT CHANGES;
-------------------------------------------------------------------------------------------------------------
For detailed information on a Query run: EXPLAIN <Query ID>;
ksql>

相关问题