kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marina Popova <ppin...@protonmail.com.INVALID>
Subject Confluent Center: KSQL query shows less results than when running from KSQL CLI
Date Tue, 07 May 2019 13:52:00 GMT
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
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message