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