ksql Push Queries - Stream İçin Tail Komutuna Benzer

Giriş

İsmi Push Queries çünkü Kafka sonuçları bize sürekli gönderiyor. Açıklaması şöyle.

A push query is a form of query issued by a client that subscribes to a result as it changes in real-time. It’s a continuous query that pushes the incremental result to the client in real-time. Push queries enable you to query a stream or materialized table with a subscription to the results

ksql 5.4'ten itibaren EMIT CHANGES kullanılması zorunlu oldu.

Örnek

Şöyle yaparız. SQL cümlesi çalıştırıldıktan sonra sadece yeni gelen veriyi göstermeye başlar.

SELECT name, countrycode FROM users_stream
EMIT CHANGES

Örnek

Şöyle yaparız. SQL cümlesi çalıştırıldıktan sonra sadece yeni gelen veriyi göstermeye başlar.

SELECT name, countrycode FROM users_stream EMIT CHANGES;

Eğer tüm veriyi görmek istersek şöyle yaparız

1. SET 'auto.offset.reset' = 'earliest';
2. SELECT name, countrycode FROM users_stream EMIT CHANGES;

Açıklaması şöyle

Please note here that, by default KSQL would only show us the new/future data and not the already-present data.

In order to view the historical data from the stream, we can modify the auto.offset.reset to ‘earliest’ value. Please note that, this property change is applicable to only this window. In case we exit and enter again to KSQL-CLI, we might have to again set this property.