Результирующий поток соединения KSQL не показывает данных - PullRequest
Новая
       100

Результирующий поток соединения KSQL не показывает данных

0 голосов
/ 14 октября 2019

Я присоединяюсь к потоку KSQL и таблице KSQL. Оба сопоставлены с одним и тем же ключом.

Но данные не поступают в результирующий поток. 

create stream kz_yp_loan_join_by_bandid WITH (KAFKA_TOPIC='kz_yp_loan_join_by_bandid',VALUE_FORMAT='AVRO') AS 
select ypl.loan_id, ypl.userid ,ypk.name as user_band_id_name 
FROM kz_yp_loan_stream_partition_by_bandid ypl 
     INNER JOIN kz_yp_key_table ypk 
     ON ypl.user_band_id = ypk.id;

Нет данных в потоке kz_yp_loan_join_by_bandid

Но если я сделаю просто:

select ypl.loan_id, ypl.userid ,ypk.name as user_band_id_name 
FROM kz_yp_loan_stream_partition_by_bandid ypl 
     INNER JOIN kz_yp_key_table ypk 
     ON ypl.user_band_id = ypk.id;

Имеются данные.

Это показывает, что поток не записывается, но почему это так?

Я попытался выполнить всю настройку снова.

1 Ответ

0 голосов
/ 14 октября 2019

Несколько вещей для проверки:

  1. Если вы хотите обработать все существующие данные, а также новые данные, убедитесь, что перед запуском CREATE STREAM … AS SELECT («CSAS») у вас естьrun SET 'auto.offset.reset' = 'earliest';
  2. Если объединение возвращает данные при запуске вне CSAS, это может быть неактуально, но всегда полезно проверить, что ваше объединение будет соответствовать всем требованиям
  3. Проверьте журнал сервера KSQL на случай, если возникнет проблема с записью в целевой теме, созданием схемы в реестре схем и т. Д.

Эти ссылки будут полезны:

...