apache-kafka - KSQL 联接和时间

Question

我需要在“登录失败”后的 10 分钟内识别出“成功登录”的客户我创建了一个“登录失败”的 Windowed KSQL 表

CREATE TABLE table_Rule200_FailedLogins WITH (TIMESTAMP='LOGDATE') AS \
SELECT CUSTID,LOGDATE,LOGIP \
FROM STREAM_DEMO_EXTRACTED \
WINDOW TUMBLING (SIZE 10 MINUTES) \
WHERE Successful_Login = 'FALSE' AND LogType = '39' \
GROUP BY CUSTID,LOGDATE,LOGIP;

我创建了一个“成功登录”流

CREATE STREAM stream_Rule200_SuccessLogins as \
select * \
FROM STREAM_DEMO_EXTRACTED WHERE LogType = '39' AND Successful_Login = 'TRUE';

KSQL 不允许我加入带有“窗口”表的流

这种情况有解决方法吗？

Answer 1

您正在谈论进行流-流连接，目前在 KSQL 中不可用（但即将推出）。

目前，您需要使用 Kafka Streams 来执行此操作。