我已经检查了融合的kafka流字数和异常检测示例。在这些示例中，结果将写入主题。取而代之的是，我如何通过 REST 或任何内容轻松快速地将结果保存到远程数据库中。融合平台中是否有任何结构
代码示例：而不是代码，发送远程数据库
wordCounts.toStream((.to("streams-wordcount-output"， Produce.with(stringSerde， longSerde((;
此处的常用模式是将流处理的结果写入 Kafka 主题，然后使用 Kafka Connect 将该主题流式传输到要将数据保存到的任何位置。Kafka Connect 是 Apache Kafka 的一部分，并且有许多连接器，包括用于将数据写入数据库(和从数据库写入(的kafka-connect-jdbc连接器。
如果直接从流应用程序写入数据库，则会不必要地将处理和存储捆绑在一起。如果数据库处于脱机状态或无法访问，则流处理必须处理该数据库。相反，将两者解耦，Kafka Connect 将处理无法访问的数据库等。