关键主题中的奇怪字符键答案

【问题标题】：strange characters key in Key topic关键主题中的奇怪字符键
【发布时间】：2021-02-20 00:47:15
【问题描述】：

我使用这个查询在 KSQLDB 中生成一个表

CREATE TABLE LimiteOneMinute_TB2
   WITH (kafka_topic='limitoneminute2', value_format='JSON') as
select (lr.rowkey) majmoo , AS_VALUE(cast(lr.rowkey as varchar)) inet_config, max(lr.inet) ip, (max(lr.rowtime) + 60000) expire_time, true as captcha
from LIMITER_REQUEST lr join CONFIG_TB lc on lr.configid = lc.id
WINDOW HOPPING (SIZE 59 SECONDS, ADVANCE BY 5 SECONDS)
group by (lr.rowkey)
having count(*) > max(lc.oneminute)
emit changes;

运行后看到输出（limitoneminute2 topic），Key有问题。

这些多余的字符是什么？我该如何清洁它们？

【问题讨论】：

标签： apache-kafka ksqldb

【解决方案1】：

当您创建窗口聚合时（正如您所做的那样），窗口构成键的一部分。因此，您在 key 中看到的是 GROUP BY 键的表示，加上窗口的开始和结束时间。

在这种情况下“清理”密钥是没有意义的，因为这样每个聚合只有一个密钥，并且没有时间窗口。

【讨论】：

谢谢。我想按键找到这些事件，所以我需要知道这个主题（例如紧凑主题）中每个事件的确切键。你有什么建议？
你在吃什么？除非有所改变，否则我不认为主题键被设计为直接使用，而是您应该使用来自应用程序的 ksqlDB 中的查询（例如使用 REST API）。