How to solve the issue of querying Kafka Streaming Data? Writing à KSQL Query
The second part of our article on querying Kafka Streaming Data.
Other articles
How to do Indexing in MongoDB with Elastic Search? Part 2
How to do Indexing in MongoDB with Elastic Search? Part 1
How to store data on browser using NoSQL IndexedDB?
How to Apply MBTI in HR: Motivation for every day. Groups of People & their Motivations
Check out our new courses
How to query time increase in Impala?
How to Apply MBTI in HR: Motivation for every day
Object-relational Mapping Using JPA, Hibernate and Spring Data JPA. Comparing the performance of persisting entities
How to implement Matrix Multiplication using Map-Reduce?
Object-relational Mapping Using JPA, Hibernate and Spring Data JPA. Comparing the approaches of persisting entities
Writing à KSQL Query
Listing 4 SQL fîr ðerfîrming stîñk ànàlysis

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

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.

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
Interested in upgrading your skills? Check out our trainings.
Siddharth Garg
Software Development Engineer