KSQL не удалось создать поток из темы - PullRequest
Новая
       10

KSQL не удалось создать поток из темы

0 голосов
/ 24 января 2019

имеет имя темы json "customer-event" и пытается создать поток из приведенного ниже KSQL: 

create stream cssc_customer_event_json (description varchar,pageEvent_id varchar)with (kafka_topic='customer-event', value_format='json');

возвращает сообщение ниже: 

 Message
------------------------------------
 Statement written to command topic
------------------------------------

после выполнения запросаи поток не был создан.Кто-нибудь может посоветовать, в чем может быть проблема?

Спасибо

С уважением, Хан

То же самое происходит, когда я пытаюсь создать таблицу. 

create stream cssc_customer_event_json (reportSuite varchar,exclude_id varchar,exclude_value varchar,exclude_description varchar,pageEvent_id varchar)with (kafka_topic='customer-event', value_format='json');

это должно создать новый поток.Но у него нет созданного потока 

ksql> show streams;

 Stream Name | Kafka Topic | Format
------------------------------------
------------------------------------
...