KSQLDB创建带句点的流/主题

Question

我希望将流/表连接在一起，但是在KSQLDB中的create stream join语句上可以做到这一点。

CREATE STREAM test_name ...... Works CREATE STREAM test.name ......不支持WOrk

我收到了一个与在名称中使用句点相关的错误。我想为我的卡夫卡主题创建一个流，其中有一个句号。

有什么想法吗？

Answer 1

标识符是表示用户定义的实体的符号，如流、表、列和其他对象。例如，如果您有一个名为s1的流，则s1是该流的标识符。默认情况下，标识符不区分大小写，这意味着s1和S1引用同一个流。在幕后，ksqlDB将标识符中的所有字符大写以备将来显示之用。

除非标识符带有反标记，否则它只能由字母、数字或下划线字符组成。对字符数没有任何限制。

为了能够在标识符中使用任何字符，您可以在声明和使用它时将其括在反引号(`)中。当您不能控制数据时，带反划线的标识符很有用，因此它可能有特殊字符，甚至关键字。当您使用带反划线的标识符时，ksqlDB会准确地捕获大小写，并且将来对该标识符的任何引用都将区分大小写。

使用KAFKA_TOPIC，您可以声明主题名称

CREATE STREAM pageviews
(viewtime BIGINT,
 userid VARCHAR,
 pageid VARCHAR)
 WITH       (KAFKA_TOPIC='page.views',
VALUE_FORMAT='DELIMITED')
 EMIT CHANGES;