KafkaCenter-Core-2.1.0.jar can not use ksql tables about kcenter HOT 6 CLOSED

confluent-5.0.0
// 20200608132645
// http://10.5.3.125:8088/info

{
"KsqlServerInfo": {
"version": "5.0.0",
"kafkaClusterId": "ISsR3iwISiKafPcLW_UkxA",
"ksqlServiceId": "default_"
}
}

[root@esTest iflytek]# curl -X "POST" "http://10.5.3.125:8088/ksql" \

 -H "Content-Type: application/json; charset=utf-8" \
 -d $'{

"ksql": "LIST tables;",
"streamsProperties": {}
}'
[{"@type":"tables","statementText":"LIST tables;","tables":[{"type":"TABLE","name":"T","topic":"json","format":"JSON","isWindowed":false},{"type":"TABLE","name":"USERS_ORIGINAL","topic":"json1","format":"JSON","isWindowed":false}]}][root@esTest iflytek]#

from kcenter.

@ljhan2 应该是版本问题，目前支持5.3,5.4.未来一周内支持ksql db0.9。由于ksql接口变化，目前无法支持以下版本。

from kcenter.

能看得懂中文就好，问题我大体上排查了一下，原因如下：
curl -X "POST" "http://10.5.3.125:8088/ksql"
-H "Content-Type: application/json; charset=utf-8"
-d $'{
"ksql": "DESCRIBE EXTENDED T;",
"id":"fhswk-kafka|default_"
}'
其中包含了 "id":"fhswk-kafka|default_"会导致运行结果出错，去掉则正确
curl -X "POST" "http://10.5.3.125:8088/ksql"
-H "Content-Type: application/json; charset=utf-8"
-d $'{
"ksql": "DESCRIBE EXTENDED T;"
}'
需要修改的代码注释即可

另外websocket监听部分协议也需要适配下
curl -X "POST" "http://10.5.3.125:8088/query"
-H "Content-Type: application/vnd.ksql.v1+json; charset=utf-8"
-d $'{
"ksql": "select * from USERS_ORIGINAL;",
"streamsProperties": {}
}'==>这样错误，需要改成
curl -X "POST" "http://10.5.3.125:8088/query"
-H "Content-Type: application/json; charset=utf-8"
-d $'{
"ksql": "select * from USERS_ORIGINAL;",
"streamsProperties": {}
}'
代码位置如下

看你的回复是目前支持5.3,5.4.建议通过

查看版本信息进行针对性的适配处理，另外提个意见

建议以追加模式以表格的形式进行展示，且带上字段名称。
看好这个工具，望越做越好

from kcenter.

from kcenter.

@ljhan2 感谢回复！我们会持续改进的。

Content-Type: application/vnd.ksql.v1+json; charset=utf-8

是因为ksql rest api 需要，虽然目前两个都可以工作，整体来看还是需要修改为官方文档需要的类型。

from kcenter.

目前marter已经支持ksql0.9.0

from kcenter.