Блог

Главная - Вопросы по программированию - KSQL не удается присоединиться к объединенным потокам , последовательная цепочка в ksql

KSQL не удается присоединиться к объединенным потокам , последовательная цепочка в ksql

#apache-kafka #confluent-platform #ksqldb #confluent-kafka-python

Вопрос:

мы используем ksqldb 0.18 и пытаемся последовательно связать несколько тем из производных потоков этих тем. Afaik базовые сообщения в производной теме могут быть объединены и запрошены с помощью ksql так же, как при создании темы самостоятельно

 CREATE STREAM IF NOT EXISTS n_stream (
    uuid VARCHAR KEY ,
    cluster_id VARCHAR
) WITH (kafka_topic='process_n', value_format='json');
CREATE STREAM IF NOT EXISTS o_stream (
    uuid VARCHAR KEY,
    project_id VARCHAR,
) WITH (kafka_topic='process_o',  value_format='json');
CREATE STREAM IF NOT EXISTS n_plus_o AS
    SELECT 
        n_stream.uuid AS uuid
    FROM n_stream
    INNER JOIN o_stream WITHIN 1 HOURS ON n_stream.uuid = o_stream.uuid;

Однако, когда я пытаюсь создать из этого новую тему, внутреннее соединение завершается беззвучно, и в конце я получаю подмножество сообщений.

 CREATE STREAM IF NOT EXISTS n_plus_o_plus_u AS
    SELECT 
        u_stream.uuid AS uuid 
    FROM n_plus_o
    INNER JOIN u_stream WITHIN 10 MINUTES ON n_plus_o.uuid = u_stream.uuid ;

Является ли это ожидаемым поведением?

TLDR : (A B) = Z; Z C не дает того же результата, что и A B C

Метки: ,