无法使用 KSQL 表访问 kafka 数据

not able to access kafka data by using KSQL tables

Kafka 主题名称：test

以下是测试题目中的数据：

{"a":1,"b":"a"} {"a":2,"b":"b"}

为此创建流如下：

创建流 test_stream123 (a INTEGER, b VARCHAR) WITH (kafka_topic='test', key='b', value_format='json');

这工作正常，甚至 Select 命令也能正确获取数据。

但问题出在 tables。

以下命令用于为上述主题创建 table：

创建 TABLE test_table (a INTEGER, b VARCHAR) WITH (kafka_topic='test', value_format='json', 键='b');

创建 table 也工作正常，响应明确说明了 "table created"。

但是，

当我尝试使用以下命令从 Kafka 获取数据时：

*select * from test_table EMIT CHANGES;*

它首先显示以下文字： => 按 CTRL-C 中断

当我按下 Ctrl-C 时，它给出以下信息：

+------------+------------+------------+--- ------+ |ROWTIME |ROWKEY |A |B | +------------+------------+------------+----------+ 查询终止

即使数据在 Kafka 主题中可用，它也会提供空数据。流工作完美，但表不工作。

查看 Jagadeesh 的个人资料Jagadeesh Musham

似乎我在处理 KSQL tables 时犯了一些小错误。你能建议我如何从中走出来吗？或发送一些链接给我，以便我完成所有这些 material 并尝试解决此案。

KSQL表仅在Kafka条目有键时显示Kafka条目。这意味着 kafka 生产者必须使用键值来生成条目。

--Jagadeesh