Giriş
Belirtilen topic'i yazdırır
FROM BEGINNING
ÖrnekAçı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