创建的表和流未显示为主题

Question

我可以在 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
---------------------------------------------------------------------------------------------------------

好吧，我需要使用来自 Java Kafka Consumer 的 RTSHTABLE 中的数据，但由于消费者无法连接到名为 RTSHTABLE 的主题，因此无法正常工作。

我在文档中读到 KTable 被视为一个主题，可以像任何其他主题一样正常使用。那么，我在这里缺少什么？

提前致谢。

Answer 1

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 …，那么它也会创建一个基础主题。