Я создаю таблицу в k sql следующим образом:
CREATE TABLE ORDERS_T (id BIGINT, product VARCHAR, quantity BIGINT, price BIGINT)
WITH (KAFKA_TOPIC='orders', VALUE_FORMAT='JSON');
В кафке я делаю "заказы" topi c
И когда я выбираю вкладку запроса в k sql даже общее количество сообщений существует, панель говорит 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..
заранее спасибо