Новый поток из темы потоковой передачи (формат Json) без каких-либо данных

Question

У меня есть потоковая тема в Json с 50 полями. Я пытаюсь создать другой поток с 1 полем, используя KSQL из темы, как показано ниже:

create stream data (timeGMT string) with (kafka_topic='json_data', value_format='json');

Поток был успешно создан, однако никакие данные не возвращаются из-под запроса KSQL:

select * from data;

Это работает на KSQL 5.0.0

Answer 1

Есть несколько вещей, которые нужно проверить, в том числе:

• Есть ли какие-либо данные в теме?

  PRINT 'json_data' FROM BEGINNING;
  

• Вы сказали, чтобы KSQL читал с самого начала темы?

  SET 'auto.offset.reset' = 'earliest';
  

• Есть ли в вашей теме сообщения, которые не являются JSON или не могут быть проанализированы?Проверьте журнал сервера KSQL на наличие ошибок.

Более подробную информацию об этих и других советах по устранению неполадок можно найти, в этом блоге .