KSQL Create Stream с пробелами в ключах - PullRequest
1 голос
/ 21 мая 2019

В операторе создания потока возникла проблема с пробелами в ключах. Например:

CREATE STREAM test ( 
    Date Time VARCHAR,
) WITH (KAFKA_TOPIC='test', VALUE_FORMAT='JSON');

Как мне обрабатывать пробелы в именах ключей?

Я пробовал:

'Date Time' VARCHAR,

и

[Date Time] VARCHAR,

Но оба дают мне постороннюю ошибку ввода.


[Обновить] Я изменил имя ключа выше с Полное имя (произвольно) на Дата и время (актуально). Также добавлено json-сообщение из источника ниже, но удалено большинство пар ключ-значение и скрыто большинство значений с xxx .

{
  "beat": {
    "hostname": "xxx",
    "version": "xxx"
  },
  "Date Time": "2019-05-21T22:18:06.000Z",
  "host": {
    "name": "xxx"
  },
  "input": {
    "type": "xxx"
  },
  "fields": {
    "env": "xxx"
  }
}

1 Ответ

0 голосов
/ 23 мая 2019

Я не думаю, что это возможно с KSQL в настоящее время (5.2.1).Я поднял https://github.com/confluentinc/ksql/issues/2871, чтобы описать и отследить проблему.

Тем временем вам нужно будет найти способ изменить имя поля, чтобы не включать пробелы.

...