KSQL 无法创建键为字符串且值为整数的流

Question

我有一个非常简单的 kafka 生产者，它使用以下方式发送数据：

ProducerRecord producerRecord = new ProducerRecord<String, Integer>(topic, symbol, value);
producer.send(producerRecord);

基本上是一个 key/value 对，其中值为整数。

如何在 ksql 中为此定义一个流？我试过了：

create stream mystream (symbol varchar) with (value_format='integer', kafka_topic='myTopic');

这给了我一个错误...查看文档我发现 value_format 仅支持分隔符、json 或 avro。而且，分隔符对我不起作用。

我只是运气不好吗？

*更新*

已接受：

create stream myStream(value INT) with (value_format='kafka', kafka_topic='myTopic');

但是我没有得到任何数据:

select * from myStream;

Answer 1

所以我的问题是双重的：

1) 我确实需要使用：

create stream myStream(value INT) with (value_format='kafka', kafka_topic='myTopic');

2) 我需要添加 Emit Changes；

select * from myStream Emit Changes;

KSQL unable to create a stream with a key of string and a value of Integer