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

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

我已经使用

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

我有一个制作人在运行,向流中注入数据。是否可以列出/显示发送到ksql流的最新项目?
谢谢
p、 我在ksql服务器上进行了尝试,结果是

  1. ksql> list streams;
  2. Stream Name | Kafka Topic | Format
  3. ---------------------------------------------------
  4. BASIC_STREAMS | main-topic | JSON
  5. ---------------------------------------------------
  6. ksql> PRINT main-topic;
  7. Could not find topic 'MAIN-TOPIC', KSQL uses uppercase.
  8. To print a case-sensitive topic apply quotations, for example: print 'topic';

当我试着

  1. ksql> print 'main-topic';

它永远挂在那里

cbeh67ev

cbeh67ev1#

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

相关问题