Тема выхода KSQL Stream

Question

Привет, у меня есть левое соединение потока Ksql (SEARCHREQUESTDTO) с таблицей Ksql (NGINX_TABLE). с помощью следующей команды ksql

CREATE STREAM NIGINX_SEARCH_QUERY AS \
  SELECT  *\
  FROM SEARCHREQUESTDTO\
  LEFT JOIN NGINX_TABLE\
    ON SEARCHREQUESTDTO.sessionid = NGINX_TABLE.sessionid;

Результирующий поток NIGINX_SEARCH_QUERY успешно. Также я могу увидеть тему NIGINX_SEARCH_QUERY с помощью команды show topic в терминале Ksql.

когда я пытаюсь подключить потребителя kafka к этой теме, потребитель не может получить какие-либо данные.

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

Answer 1

Если PRINT показывает вывод, тогда тема существует и имеет данные .

Если ваш потребитель не показывает вывод, то это ошибка вашего потребителя. Поэтому я бы перефразировал ваш вопрос следующим образом: у меня есть тема Кафки, для которой мой Потребитель не показывает данные.

Я бы использовал kafkacat для внешней проверки темы:

      kafkacat -b kafka-broker:9092 -C -K: \
      -f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
      -t NIGINX_SEARCH_QUERY