Пустой поток KSQL - PullRequest
Новая
       6

Пустой поток KSQL

1 голос
/ 02 мая 2019

У меня проблема с получением данных из темы Кафки. этот объект содержимого темы, я действительно не знал, как сохранить некоторую переменную в потоке. и я уверен, что тема существует

у меня есть: 

Ticket object:{

header object{storeID,storename.....}

body object{...}

}

Я хочу поместить storeID в поток 

create stream test (StoreID VARCHAR) with (KAFKA_TOPIC= 'output__tfrema',VALUE_FORMAT='AVRO');

Я попробую этот пример, но он даст мне 0 данных, я ожидаю, что он даст мне по крайней мере 10000 данных.

спасибо в любом случае

1 Ответ

0 голосов
/ 02 мая 2019

Если результаты не возвращаются, это может быть по нескольким причинам.

  • Убедитесь, что у вас SET 'auto.offset.reset' = 'earliest';, поэтому вы читаете все сообщения в начале темы
  • ЕстьЕсть ли ошибки десериализации в журнале вашего сервера KSQL?

Подробнее вы можете прочитать здесь: https://www.confluent.io/blog/troubleshooting-ksql-part-1

...