【发布时间】：2020-08-17 08:43:07
【问题描述】：
Kafka 主题名称：test
以下是测试题目中的数据：
{"a":1,"b":"a"} {"a":2,"b":"b"}
为此创建了流：
CREATE STREAM test_stream123 (a INTEGER, b VARCHAR) WITH (kafka_topic='test', key='b', value_format='json');
这工作正常，甚至 Select 命令也能正确获取数据。
但问题在于表格。
以下命令用于为上述主题创建表格：
CREATE TABLE test_table (a INTEGER, b VARCHAR) WITH (kafka_topic='test', value_format='json', key='b');
创建表也可以正常工作，并且响应清楚地说明了“已创建表”。
但是，
当我尝试使用以下命令从 Kafka 获取数据时：
*select * from test_table EMIT CHANGES;*
它首先显示以下文本： => 按CTRL-C打断
当我按下 Ctrl-C 时，它会给出以下消息：
+-----------+-----------+-----------+------- ----+ |ROWTIME |ROWKEY |A |B | +-----------+------------+------------+-----------+ 查询已终止
即使数据在 Kafka 主题中可用，它也会提供空数据。流工作完美，但表格不工作。
查看 Jagadeesh 的个人资料 Jagadeesh Musham
似乎我在处理 KSQL 表时犯了一些小错误。你能建议我如何摆脱这种情况吗？或发给我一些链接，以便我浏览所有材料并尝试解决此案。
【问题讨论】：
标签： ksqldb