我已经使用
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';
它永远挂在那里
1条答案
按热度按时间cbeh67ev1#
您可以运行:
PRINT 'main-topic' FROM BEGINNING;
查看主题中的所有行。打印“主要主题”;查看添加到主题的所有行
PRINT main-topic;在ksqldb的较新版本中,主题名区分大小写 或者
SELECT * FROM basic_streams;` 以更sql的方式实现同样的功能。