【发布时间】: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';
它永远挂在那里
【问题讨论】:
-
你试过
PRINT main-topic吗? -
这是在 kafka 还是 ksql 服务器中?
-
好吧,
PRINT不是 Kafka 术语,所以 KSQL github.com/confluentinc/ksql/issues/261#issuecomment-325859822 并且它挂起等待来自最新偏移量的数据
标签: apache-kafka ksqldb