我正在使用KSQL在kafka中工作。我想找出最后一行在5分钟内不同的DEV_NAME(ROWKEY)。因此,我创建了用于进一步连接的流和聚合表。在下面的KSQL中,我已经创建了一个表,用于查找不同DEV_NAME在5分钟内的最后一行 CREATE TABLE TESTING_TABLE AS
SELECT ROWKEY AS DEV_NAME, max(ROWTIME) as LAST_TIM
我已经使用KSQL创建了一个流和该流的聚合表。{
"ksql":"DROP Stream IF EXISTS StreamLegacyNames; DROP Stream IF EXISTS StreamLegacy; CREATE StreamStreamLegacyNames As Select payload->AgeYr Age from StreamLegacy; Create Table DimAge As SE
在流-流连接查询结果上,我面临着一种意想不到的行为。KSQL版本: 5.1.3#1.CREATE STREAM streamAWITH (KAFKA_TOPIC='topicA', VALUE_FORMAT='JSON');
FROM streamB b on b.id = a.id;在这种情况下,当我进行以下
我正在研究一些工作,我们必须证明Kafka和KSQL作为POC的一部分的价值。我们正在处理简单的游戏事件,玩家可以进行游戏,而游戏引擎要么给他们分配分数(被认为是胜利),要么他们什么也得不到(被认为是输球)。我们的要求之一是证明在连续亏损或获胜时使用KSQL的可行性。cannot be cast to io.confluent.ksql.parser.tree.ComparisonExpression
最初我认为这与WHERE子句有关,但在查看之后,问题似乎与JOIN当