我像这样在 ksql 中创建表:
CREATE TABLE ORDERS_T (id BIGINT, product VARCHAR, quantity BIGINT, price BIGINT)
WITH (KAFKA_TOPIC='orders', VALUE_FORMAT='JSON');
在卡夫卡我有“订单”主题
当我在 ksql 中选择查询选项卡时,即使存在总消息,面板 No new messages
如下所示
那么我该如何解决呢?我想在confluent.io中看到类似这个例子的结果
如果我不使用EMIT CHANGES
它会给出这个错误:
Table 'MYTABLE' is not materialized. Refer to https://cnfl.io/queries for info on query types. If you..
提前致谢