Kafka topica name: test
Ниже приведены данные в тесте topi c:
{"a": 1, "b ":" a "} {" a ": 2," b ":" b "}
Создал поток для этого как:
CREATE STREAM test_stream123 ( a INTEGER, b VARCHAR) WITH (kafka_topic = 'test', key = 'b', value_format = '* json');
Это работает нормально, и даже команда Select также правильно выбирает данные .
Но проблема в таблицах.
Следующая команда используется для создания таблицы с указанным выше топи c:
CREATE TABLE test_table (INTEGER , b VARCHAR) WITH (kafka_topic = 'test', value_format = 'json', key = 'b');
Создание таблицы также работало нормально, и в ответе четко указано "таблица создана ".
Но,
Когда я попытался извлечь данные из Kafka, используя следующую команду:
* select * from test_table EMIT CHANGES; *
сначала отображается следующий текст: => Нажмите CTRL- C прерывать
И когда я нажимаю Ctrl- C, он выдает следующее сообщение:
+ ----------- + ----------- + ----------- + ----------- + | ROWTIME | ROWKEY | A | B | + ----------- + ----------- + ----------- + ----------- + Запрос прекращено
Дает пустые данные, даже если данные доступны в Kafka topi c. Потоки работают отлично, но таблицы не работают.
Просмотр профиля JagadeeshJagadee sh Musham
Похоже, я совершил небольшую ошибку при работе с таблицами K SQL. Не могли бы вы подсказать мне, как выйти из этого. или пришлите мне несколько ссылок, чтобы я мог go разобраться со всем этим материалом и попытаться раскрыть дело.
заранее спасибо,
- Jagadee sh Musham.