KSQL 表不显示数据，但具有相同结构的流返回数据

Question

我在 KSQL 中创建了一个表，而查询它没有返回任何数据。然后我在相同的主题上创建了一个具有相同结构的流，我可以查询数据。

我在这里错过了什么。我需要这个作为加入流的表。

CREATE TABLE users_table \
(registertime bigint, userid varchar, regionid varchar, gender varchar) \
WITH (value_format='json', kafka_topic='users_topic',key='userid');

和

CREATE STREAM users_stream \
(registertime bigint, userid varchar, regionid varchar, gender varchar) \
 WITH (value_format='json', kafka_topic='users_topic');

提前致谢。

Answer 1

如果您将一个主题作为 a 阅读，则该主题中TABLE的消息必须设置密钥。如果键是null，记录将被静默删除。KSQLTABLE中的键是主键，null对于主键来说不是有效值。

此外，键属性的消息中的值必须与键相同（注意，模式本身是在消息的值上定义的）。例如，如果您有一个架构，<A,B,C>并且您将其设置A为键，则主题中的消息必须是<key,value> == <a,<a,b,c>>. 否则，您将得到错误的结果。