如何在ksql流中列出/显示最新数据

Question

我已经使用创建了一个ksql流

CREATE STREAM basic_streams (data VARCHAR) 
WITH (KAFKA_TOPIC='main-topic',VALUE_FORMAT='JSON');

我有一个生产者在运行，把数据注入流中。是否可以列出/显示发送到ksql流的最新项目？

感谢

附言：我在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';

它永远挂在那里

Answer 1

您可以运行：

• PRINT 'main-topic' FROM BEGINNING;查看主题中的所有行
• `打印"主要主题"；查看添加到主题中的所有行
• 较新版本的ksqlDB中的PRINT main-topic;，因为主题名称区分大小写
• 或者SELECT * FROM basic_streams;以一种更SQL的方式实现相同的功能