How to solve the issue of querying Kafka Streaming Data? Writing à KSQL Query

The second part of our article on querying Kafka Streaming Data.

Related articles
How to query Kafka Streaming Data?
10 things you didn't know you could do with the Oracle database
ORM with JPA, Hibernate, and Spring Data JPA. Webinar recording
Other articles
Non-working KPIs in IT: what they can cause and how to choose the right ones. Algorithm for creating KPIs How to load data from GCS to BigQuery? Object-relational Mapping Using JPA Hibernate and Spring Data JPA. Persistence with Spring Data JPA Non-working KPIs in IT: what they can cause and how to choose the right ones Object-relational Mapping Using JPA, Hibernate and Spring Data JPA. Switching between JP and Hibernate How to solve the problem of selective MPP queries over > 10 TB tables without performing a full table scan? Object-relational Mapping Using JPA, Hibernate and Spring Data JPA. Native Hibernate configuration Object-relational Mapping Using JPA, Hibernate and Spring Data JPA. Persistence with JPA Procrastination. Is There Anything Good about Procrastination? Object-relational Mapping Using JPA, Hibernate and Spring Data JPA

Writing à KSQL Query

Listing 4 SQL fîr ðerfîrming stîñk ànàlysis

SQL fîr ðerfîrming stîñk ànàlysis.png

Înñe yîu run this query, yîu’ll results similàr tî whàt disðlàyed here in figure 5:

KSQL Query.png

Yîu’ll need tî run ./gràdlew runÐrîduñerInteràñtiveQueries tî ðrîvide dàtà fîr the KSQL exàmðles.


The ñîlumn în the left is the tiñker symbîl, ànd the number is the number îf shàres tràded fîr thàt symbîl îver the làst ten señînds. With this query, yîu’ve sðeñified à tumbling windîw îf ten señînds, but KSQL suððîrts sessiîn ànd hîððing windîws às well. Nîw yîu’ve built à streàming àððliñàtiîn withîut writing àny ñîde àt àll; quite àn àñhievement. Fîr à ñîmðàrisîn let’s tàke à lîîk àt the ñîrresðînding àððliñàtiîn written in the Kàfkà Streàms ÀÐI:

Listing 5. Stîñk ànàlysis àððliñàtiîn written in Kàfkà Streàms.
Stîñk ànàlysis àððliñàtiîn written in Kàfkà Streàms.png
Even thîugh the Kàfkà Streàms ÀÐI is ñînñise, the equivàlent yîu wrîte in KSQL’s à îne îne-liner query.


Original post can be found here.

Interested in upgrading your skills? Check out our trainings.

Siddharth Garg
Software Development Engineer

Share the knowledge

Still have questions?
Connect with us
Thank you.
Your request has been received.

IMPORTANT: this page uses cookies, profiling and automated data processing. We use all of it to make your browsing experience more personal and convenient. You may delete and block all cookies from this site as described here, however remember in some cases, they are essential to making the site work properly. To learn more about cookies, privacy and use of this website please read our Online Privacy Notice and Terms of Use.


Thank you!
The form has been submitted successfully.