2

我使用创建了一个 ksql 流

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

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

谢谢

PS我在ksql server中试过，结果是

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';

它永远挂在那里

4

1 回答 1

0

你可以运行：

  • PRINT 'main-topic' FROM BEGINNING;查看主题中的所有行。
  • `打印'主要主题'; 查看添加到主题的所有行
  • PRINT main-topic;在更新版本的 ksqlDB 中，主题名称区分大小写
  • 或者SELECT * FROM basic_streams;以更 SQL 的方式实现相同的目的。
于 2020-05-22T12:20:38.433 回答