K SQL не удалось создать поток с ключом строки и значением Integer

Question

У меня есть очень простой производитель kafka, который отправляет данные с использованием следующего:

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

в основном пара ключ / значение, где значение является целым числом.

Как определить поток для этого в k sql? Я попытался:

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;