【问题标题】:How to list/show most recent data in a ksql stream?如何列出/显示 ksql 流中的最新数据?
【发布时间】:2019-01-04 18:02:42
【问题描述】:

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

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

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

谢谢

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

它永远挂在那里

【问题讨论】:

标签: apache-kafka ksqldb


【解决方案1】:

你可以运行:

  • PRINT 'main-topic' FROM BEGINNING; 查看主题中的所有行。
  • `打印'主主题';查看添加到主题的所有行
  • PRINT main-topic; 在 ksqlDB 的更新版本中,因为主题名称区分大小写
  • SELECT * FROM basic_streams; 以更 SQL 的方式实现相同的目的。

【讨论】:

    猜你喜欢
    • 2018-10-05
    • 1970-01-01
    • 1970-01-01
    • 2018-02-21
    • 1970-01-01
    • 2019-02-10
    • 1970-01-01
    • 2017-12-18
    • 2019-04-06
    相关资源
    最近更新 更多