В таблице ksql нет данных после создания таблицы по теме kafka - PullRequest
Новая
       16

В таблице ksql нет данных после создания таблицы по теме kafka

0 голосов
/ 12 июня 2019

Я пытаюсь создать таблицу ksql из существующей темы в kafka. Когда я запрашиваю таблицу, никакие данные не отображаются.

Я пытался выдавать сообщения в тему кафки с ключами. Они видны в потоке ksql, который я создал, но когда я создаю похожую таблицу, в ней нет данных.

Производство данных: 

sh kafka-console-producer \
--broker-list kf-pranay-kafka-0.kf-pranay-kafka-headless.default.svc.cluster.local:9092 \
--topic ppp \
--property "parse.key=true" \
--property "key.separator=:"
1:{"sr":"1","title":"The Matrix","year":1999,"genres":"Science Fiction"}
2:{"sr":"2","title":"Die Hard","year":1988,"genres":"Action"}
3:{"sr":"3","title":"Toy Story","year":1995,"genres":"Animated"}

Создание и запрос потока: 

ksql> SET 'auto.offset.reset'='earliest';
Successfully changed local property 'auto.offset.reset' from 'earliest' to 'earliest'.
ksql>
ksql> CREATE STREAM ppp (sr varchar, title varchar, year bigint, genres varchar) WITH
>(kafka_topic='ppp', value_format='JSON');

 Message
----------------
 Stream created
----------------
ksql>
ksql> SELECT * FROM ppp;
1560340201759 | 1 | 1 | The Matrix | 1999 | Science Fiction
1560340201767 | 2 | 2 | Die Hard | 1988 | Action
1560340201767 | 3 | 3 | Toy Story | 1995 | Animated
^CQuery terminated
ksql>
ksql> CREATE TABLE movie_table (sr varchar, title varchar, year bigint, genres varchar) WITH
>(kafka_topic='ppp', value_format='JSON', key = 'sr');

 Message
---------------
 Table created
---------------
ksql>
ksql> SELECT * FROM MOVIE_TABLE;
^CQuery terminated

Я ожидаю такой же вывод из таблицы, как запрос SELECT из STREAM. Но, похоже, я не получаю никаких данных в таблице.

...