You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Marina Popova <pp...@protonmail.com.INVALID> on 2019/05/07 13:52:00 UTC

Confluent Center: KSQL query shows less results than when running from KSQL CLI

Hi!
I'm running the same query from KSQL CLI and from the Confluent Control Center (KSQL Development).
I set 'auto.offset.reset' = 'latest';
to only use latest events.

Once I send 20 test events - I get full (correct) results from this query in KSQL CLI - but only partial results in the Control Center.

Here is the query:

SELECT sitekey,

      windowStart() as window_start,

      windowEnd() as window_end,

      TOPK(request_time, 3) as top_3_request_times

FROM rc_events_full

WINDOW TUMBLING (SIZE 30 SECONDS)

GROUP BY sitekey;

Here are the results from the KSQL CLI:

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [0.014]

8vGuAWfMScPzFg | 1557193050000 | 1557193080000 | [0.062]

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [0.441, 0.014]

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [4.682, 0.441, 0.014]

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [4.682, 0.441, 0.021]

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [4.682, 0.441, 0.033]

Gja7Vp7jFJqgpw | 1557193020000 | 1557193050000 | [3.012]

Gja7Vp7jFJqgpw | 1557193020000 | 1557193050000 | [3.012, 0.013]

Gja7Vp7jFJqgpw | 1557193020000 | 1557193050000 | [3.012, 0.013, 0.004]

8vGuAWfMScPzFg | 1557193020000 | 1557193050000 | [4.682, 0.51, 0.441]

Gja7Vp7jFJqgpw | 1557193020000 | 1557193050000 | [3.012, 0.013, 0.004]

8vGuAWfMScPzFg | 1557193050000 | 1557193080000 | [0.062, 0.0]

8vGuAWfMScPzFg | 1557193050000 | 1557193080000 | [0.062, 0.008, 0.0]

8vGuAWfMScPzFg | 1557193050000 | 1557193080000 | [0.063, 0.062, 0.008]

8vGuAWfMScPzFg | 1557193050000 | 1557193080000 | [1.624, 0.063, 0.062]

5nrqWz99We6-2Q | 1557193020000 | 1557193050000 | [0.075]

5nrqWz99We6-2Q | 1557193020000 | 1557193050000 | [0.075, 0.002]

5nrqWz99We6-2Q | 1557193020000 | 1557193050000 | [0.175, 0.075, 0.002]

AkSEBdGdUYrgSA | 1557193020000 | 1557193050000 | [0.0]

5nrqWz99We6-2Q | 1557193020000 | 1557193050000 | [0.175, 0.075, 0.002]

Here are the results from the Control Center:
PAYLOAD__SITEKEY  WINDOW_START   WINDOW_END     TOP_3_REQUEST_TIMES

AkSEBdGdUYrgSA  1557193020000 1557193050000 [0]
8vGuAWfMScPzFg  1557193050000 1557193080000 [1.624,0.062,0]
5nrqWz99We6-2Q   1557193020000 1557193050000 [0.001]

This is not the only query I see only partial results in the Control Center for.... Is there some configuration I'm missing?

Thank you!
Marina