ksqlDB 是学习和开发 kafka 流式计算的很方便的工具。它支持 Push Query 和 Pull Query。下面是一些 Pull Query 的测试。 测试对象 我建立了下面的 stream 作为测试对象： CREATE OR REPLACE STREAM tagvalue (tagId INT, value DOUBLE)WITH (kafka_topic='tagvalue'

根据 ksqlDB 的文档，创建一个带主键的 stream 语法如下： CREATE OR REPLACE STREAM tagvalue (tagId INT, value DOUBLE)WITH (kafka_topic='tagvalue', key='tagId', value_format='json', partitions=1); 但是运行后，会看到以下错误： Invalid