主键为整数时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
相关产品推荐
相关产品推荐

