Wednesday, May 3, 2023

ksql PRINT

Giriş
Belirtilen topic'i yazdırır

FROM BEGINNING
Örnek
Açıklaması şöyle
Please note that, by default KSQL is going to show us only the latest data arriving into the topic and not the historical data. 
Şöyle yaparız
ksql> print 'demo.demo.orders' from beginning; 

Key format: SESSION(KAFKA_STRING) or HOPPING(KAFKA_STRING) 
or TUMBLING(KAFKA_STRING) or KAFKA_STRING 

Value format: AVRO 

rowtime: 2020/07/13 14:36:53.207 Z, key: ..., value: ...
LIMIT
Normalde print komutu sonlanmaz, yeni girdi bekleyeme devam eder. Çıktıyı sınırlamak ve komutu sonlandırmak için LIMIT kullanılır
Örnek
Şöyle yaparız
ksql> print 'demo.demo.orders' from beginning lim1t 1; 
...
ksql>

No comments:

Post a Comment

kafka-consumer-groups.sh komutu

Giriş Bir topic'i dinleyen consumer'ları gösterir. Aynı topic'i dinleyen consumer group'ları olabilir. Her topic farklı part...