KSQL table 不显示数据但具有相同结构的 Stream 返回数据

Question

我在 KSQL 中创建了一个 table，查询它时没有返回任何数据。然后我在同一主题上创建了一个具有相同结构的流，并且我能够查询数据。

我在这里错过了什么。我需要它作为 table 加入流。

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

如果您将主题阅读为 TABLE，则该主题中的消息必须设置密钥。如果键是 null，记录将被静默删除。 KSQL 中的键 TABLE 是主键，null 不是主键的有效值。

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

KSQL table 不显示数据但具有相同结构的 Stream 返回数据

KSQL table not showing data but Stream with same structure returning data

apache-kafka

ksqldb