如何以编程方式插入流？
How to insert into stream programmatically?
我收到了来自生产者的几条消息，我需要将它们存储到流中，但我不想从 ksqldb 控制台手动执行，需要通过编程处理这些插入 (Python/Java).谁能告诉我示例代码或任何参考资料？
谢谢！
您可以使用 REST API 或 Java 客户端与 ksqlDB 交互。这是 Java 客户端的文档，其中包含用于插入的代码片段：https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-clients/java-client/#stream-inserts.
我收到了来自生产者的几条消息，我需要将它们存储到流中，但我不想从 ksqldb 控制台手动执行，需要通过编程处理这些插入 (Python/Java).谁能告诉我示例代码或任何参考资料？ 谢谢！
您可以使用 REST API 或 Java 客户端与 ksqlDB 交互。这是 Java 客户端的文档，其中包含用于插入的代码片段：https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-clients/java-client/#stream-inserts.