apache-kafka - 数据不在创建的 ksql 表中

Question

我创建了一个新主题并为该主题生成数据。然后创建了一个新表，但是当我尝试显示数据时，它抛出了一个错误。

生产者命令：kafka-console-producer --broker-list localhost:9092 --topic timestamp_data --property "parse.key=true" --property "key.separator=:"

我正在制作的数据。

key1:key1,value1

key2:key2,value2

key3:key3,value3

表命令：CREATE TABLE TIMESVALUE (ARTTYPE VARCHAR PRIMARY KEY, VALUE VARCHAR) WITH (KAFKA_TOPIC='timestamp_data', KEY_FORMAT='KAFKA', VALUE_FORMAT='DELIMITED');

现在，当我尝试使用select * from TIMESVALUE;低于错误的命令显示数据时

Can't pull from `TIMESVALUE` as it's not a materialized table. See https://cnfl.io/queries for more info.
Add EMIT CHANGES if you intended to issue a push query

我也试过了EMIT CHANGES，得到了下面的空响应。我已经尝试添加更多数据，但它没有出现。我在制作时正在做的 KEY 有什么问题吗？请帮忙。

更新：

我开始生成如下数据，并且能够在 select 命令中看到数据。

key1:value1
key2:value2
key3:value3
key1:value2

现在的问题是如何获得特定键的最新值。例如，根据上面的数据，key1它应该返回value2唯一的。

标签： apache-kafkaksqldb