You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

主键为整数时KSQL Pull查询异常问题求助

KSQL Pull查询异常问题

环境:Kubernetes 部署的 Confluent Helm 7.5.1

通过聚合表创建新表后,KSQL Pull 查询出现异常:只有使用emit changes语法,或者in子句包含至少两个参数时,查询才能正常返回结果。

执行的查询示例

ksql> select custid from AAAAA where custid=15555;
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID                                                                                                                                                                                                    |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
Query terminated
ksql> select custid from AAAAA where custid in (15555, 0);
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID                                                                                                                                                                                                    |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|15555                                                                                                                                                                                                     |
Query terminated
ksql> select custid from AAAAA where custid=15555 emit changes limit 1;
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID                                                                                                                                                                                                    |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|15555                                                                                                                                                                                                     |
Limit Reached
Query terminated

聚合查询时的警告信息(推测为等待主题创建所致)

[2023-10-30 10:44:04,596] WARN [消费者客户端ID=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-9fb9d9e1-4d97-4747-9146-bd9b74f5ad2f-StreamThread-1-consumer, 组ID=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881] 获取关联ID为68的元数据时出错:{_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000012-topic=未知主题或分区, _confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-Aggregate-GroupBy-repartition=未知主题或分区} (org.apache.kafka.clients.NetworkClient)

内容的提问来源于stack exchange,提问作者taymedee

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.07 15:57:45