ksqlDB java 客户端：无法从 client.executeStatement() 反序列化数据
我正在尝试使用 Java ksqlDb-api-client:0.24.0 使用下面的代码查询汇合云上的 KSQL 流 ClientOptions options = ClientOptions.create() .setHost(KS…
KSQL 查询检查值完整性
组成的流 我有一个由以下示例值、 correlation_id 和 event_type 示例 aud-103触发器 aud-104触发器 aud-109 缓解措施 aud-103 缓解 如果检测到具有相…
KSQL：无效的连接条件：当连接超过 2 个表时，不支持将外键表-表连接作为 n 路的一部分
我有 3 个主题，其中包含 KAFKA_INT 关键 客户、订单、订单详细信息 当我仅连接 2 个表时 select * from orders o join customer c on o.custid = c.c…
窗口 KTable 上的 Kafka 操作
我想对窗口 KTable 进行一些进一步的操作。为了提供一些背景知识，我有一个主题，其数据格式为：{clientId, txTimestamp, txAmount}。从本主题中，我…
如何使用 ksql 将 String 类型转换为结构数组
我在 Kafka 中有一个主题，其架构如下： Name Type ID STRING ORDER_STATUS INTEGER ORDER_ITEM_JSON STRING ORDER_ITEM_JSON 本身是一个项目字符串：…
- 共 1 页
- 1
