【发布时间】:2022-01-19 21:50:09
【问题描述】:
我收到了来自生产者的几条消息,我需要将它们存储到流中,但我不想从 ksqldb 控制台手动执行,需要通过编程(Python/Java)处理这些插入。有人可以给我看示例代码或任何参考吗? 谢谢!
【问题讨论】:
标签: ksqldb
我收到了来自生产者的几条消息,我需要将它们存储到流中,但我不想从 ksqldb 控制台手动执行,需要通过编程(Python/Java)处理这些插入。有人可以给我看示例代码或任何参考吗? 谢谢!
【问题讨论】:
标签: ksqldb
您可以使用 REST API 或 Java 客户端与 ksqlDB 进行交互。这是 Java 客户端的文档,其中包含用于插入的代码 sn-p:https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-clients/java-client/#stream-inserts。
【讨论】: