KSQL 在键中使用空格创建流

Question

在创建流语句中，我遇到了键中空格的问题。例如：

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

我应该如何处理键名中的空格？

我试过：

'Date Time' VARCHAR,

和

[Date Time] VARCHAR,

但两者都给我无关的输入错误。

[更新] 我将上面的键名从 Full Name（任意）更改为 Date Time（实际）。还添加了来自下方源的 json 消息，但去除了大部分键值对并使用 xxx 隐藏了大多数值。

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

Answer 1

我认为目前的 KSQL (5.2.1) 无法做到这一点。我提出了 https://github.com/confluentinc/ksql/issues/2871 来描述和跟踪问题。

与此同时，您需要想办法将字段名称更改为不包含空格。

KSQL 在键中使用空格创建流

KSQL Create Stream with spaces in keys

ksqldb