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

2izufjch  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(522)

我已经使用

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

我有一个制作人在运行,向流中注入数据。是否可以列出/显示发送到ksql流的最新项目?
谢谢
p、 我在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';

它永远挂在那里

cbeh67ev

cbeh67ev1#

您可以运行: PRINT 'main-topic' FROM BEGINNING; 查看主题中的所有行。
打印“主要主题”;查看添加到主题的所有行PRINT main-topic;在ksqldb的较新版本中,主题名区分大小写 或者SELECT * FROM basic_streams;` 以更sql的方式实现同样的功能。

相关问题