Kafka 如果主键为整数,则KSQL拉式查询无法正常工作

h9vpoimq  于 2023-11-16  发布在  Apache
关注(0)|答案(1)|浏览(103)

我已经从另一个聚合表创建了一个表,但是pull查询似乎不能正常工作,它只对emit changesin子句(至少2个参数)正常工作我使用的是Kubernetes Confluent Helm version 7.5.1

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 [Consumer clientId=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-9fb9d9e1-4d97-4747-9146-bd9b74f5ad2f-StreamThread-1-consumer, groupId=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881] Error while fetching metadata with correlation id 68 : {_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000012-topic=UNKNOWN_TOPIC_OR_PARTITION, _confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-Aggregate-GroupBy-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)

2skhul33

2skhul331#

好了,最后是PROTOBUF的问题。我已经改变了所有的格式,以AVRO和工作与整数现在罚款

相关问题