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

Question

Иметь имя темы 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
------------------------------------
------------------------------------

Answer 1

Сообщение:

Statement written to command topic

Обычно это видно только тогда, когда поток конечных точек REST записывает сообщение в тему команды, а затем истекает время ожидания со стороны механизма, чтобы прочитать сообщение и обработать его.

Это может произойти по двум причинам:

1. В Kafka есть неправильная конфигурация, останавливающая чтение со стороны движка, например, ACL установлены неправильно, поэтому ksqlDB может писать, но не может читать данные.
2. В Kafka есть проблема со стабильностью - например, уязвимые разделы и т. Д., Хотя это имеет тенденцию останавливать работу записи в Kafka, а не на стороне чтения.
3. Поток, читающий тему команды, разбился. Это могло быть вызвано некоторыми ошибками в более ранних версиях. Журнал приложения ksql сообщит об этом. Это может исправить перезапуск или обновление.
4. Поток, читающий тему команды, застрял. Это могло быть вызвано некоторыми ошибками в более ранних версиях. Журнал приложения ksql НЕ сообщит об этом. Вам нужно будет сделать дамп потока или что-то подобное для диагностики. Это может исправить перезапуск или обновление.