KSQL 连接和时间

Question

我需要识别 "failed login" 10 分钟内有 "successful login" 的客户我创建了 "failed logins"

的窗口化 KSQL TABLE

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;

我创建了 "successfull logins"

的 STREAM

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

KSQL 不允许我加入 "windowed" table

的流

这种情况有解决办法吗？

Answer 1

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

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

KSQL 连接和时间

KSQL JOINS and TIME

apache-kafka

ksqldb