Как вывести / отобразить самые последние данные в потоке ksql?
Я создал поток ksql, используя
CREATE STREAM basic_streams (data VARCHAR) \
WITH (KAFKA_TOPIC='main-topic',VALUE_FORMAT='JSON');
У меня работает продюсер, качающий данные в поток. Можно ли перечислить / показать самые последние элементы, отправленные в поток ksql?
Спасибо
PS я пробовал в ksql сервере и результаты
ksql> list streams;
Stream Name | Kafka Topic | Format
---------------------------------------------------
BASIC_STREAMS | main-topic | JSON
---------------------------------------------------
ksql> PRINT main-topic;
Could not find topic 'MAIN-TOPIC', KSQL uses uppercase.
To print a case-sensitive topic apply quotations, for example: print 'topic';
и когда я попробовал
ksql> print 'main-topic';
он висит там навсегда
0 ответов
Вы можете запустить:
PRINT 'main-topic' FROM BEGINNING;
чтобы увидеть все строки в теме.- `PRINT 'main-topic'; чтобы увидеть все строки, добавленные в тему
PRINT main-topic;
в более поздних версиях ksqlDB, поскольку имя темы чувствительно к регистру- Или
SELECT * FROM basic_streams;
чтобы добиться того же с помощью SQL.