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

Consumer Failover Across Data Centers

Active-Passive Consumption Across Data Centers Açıklaması şöyle In Kafka, a common consumption pattern for multi-data center setups in...