Созданные таблицы и потоки не отображаются как темы - PullRequest
Новая
       9

Созданные таблицы и потоки не отображаются как темы

0 голосов
/ 16 апреля 2019

Я могу успешно создавать и просматривать таблицы и потоки в KSQL, но они не отображаются как темы, поэтому я могу использовать их на Java Kafka Consumer.

Кратко о том, что происходит: 

ksql> CREATE TABLE RTSHTABLE (primaryKey BIGINT, secondaryKey BIGINT) WITH (KAFKA_TOPIC = 'rtsh', VALUE_FORMAT='JSON', KEY='primaryKey');

 Message
---------------
 Table created
---------------


ksql> SHOW TABLES;

 Table Name | Kafka Topic | Format | Windowed
----------------------------------------------
 RTSHTABLE  | rtsh        | JSON   | false
----------------------------------------------

ksql> SHOW STREAMS;

 Stream Name         | Kafka Topic                 | Format
------------------------------------------------------------
 RTSHSTREAM          | rtsh                        | JSON
 KSQL_PROCESSING_LOG | default_ksql_processing_log | JSON
------------------------------------------------------------

ksql> SELECT * FROM RTSHTABLE LIMIT 5;
1555406522968 | m�l | 1830743660 | 1968383301
1555406522969 | 0��N | 819984462 | 1390795850
1555406522969 | m�� | 1830743753 | 1968383301
1555406522969 | m� | 1830743691 | 1968383301
1555406523501 | o)� | 1865005575 | 797470537
Limit Reached
Query terminated

ksql> SHOW TOPICS;

 Kafka Topic                 | Registered | Partitions | Partition Replicas | Consumers | ConsumerGroups
---------------------------------------------------------------------------------------------------------
 default_ksql_processing_log | true       | 1          | 1                  | 0         | 0
 rtsh                        | true       | 1          | 1                  | 0         | 0
---------------------------------------------------------------------------------------------------------

Что ж, мне нужно использовать данные из RTSHTABLE от Java Kafka Consumer, но он не работает, поскольку потребитель не может подключиться к теме с именем RTSHTABLE.

Я прочитал в документации, чтоKTable рассматривается как тема и может потребляться как любая другая тема.Итак, что мне здесь не хватает?

Заранее спасибо.

1 Ответ

1 голос
/ 16 апреля 2019

Тема для RTSHTABLE - rtsh.Это именно то, что SHOW TABLES говорит вам: 

ksql> SHOW TABLES;

 Table Name | Kafka Topic | Format | Windowed
----------------------------------------------
 RTSHTABLE  | rtsh        | JSON   | false
----------------------------------------------

Таблицы и потоки - это просто семантические модели в топе тем.В указанном вами коде SQL вы просто «регистрируете» таблицу в существующей теме.

Если вы CREATE STREAM foo AS SELECT … или CREATE TABLE foo AS SELECT …, то это также создаст основную тему.

...