KSQL 无法使用字符串键和整数值创建流答案

【问题标题】：KSQL unable to create a stream with a key of string and a value of IntegerKSQL 无法使用字符串键和整数值创建流
【发布时间】：2020-05-14 00:31:26
【问题描述】：

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

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

基本上是一个键/值对，其中的值是一个整数。

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

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

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

我是不是运气不好？

* 更新 *

它接受了：

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

但是当我这样做时我没有得到任何数据：

select * from myStream;

【问题讨论】：

【解决方案1】：

所以我的问题是双重的：

1) 我确实需要使用：

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

2) 我需要添加 Emit Changes；

select * from myStream Emit Changes;

【讨论】：