我已经检查了融合的kafka流wordcount和异常检测示例。在这些示例中，结果被写入主题。而不是这个如何通过REST或任何方式快速地将结果保存到远程数据库中。汇合平台中是否有任何结构
代码示例：//代替代码，发送远程数据库
wordCounts.toStream（）。to（“streams-wordcount-output”，Produced.with（stringSerde，longSerde））;
这里通常的模式是将流处理的结果写入Kafka主题，然后使用Kafka Connect将该主题流式传输到您希望保留数据的任何位置。 Kafka Connect是Apache Kafka的一部分，有许多连接器，包括用于向（和从）数据库写入数据的kafka-connect-jdbc。
如果您直接从您的流应用程序写入数据库，则不必要地将您的处理和存储捆绑在一起。如果数据库脱机或无法访问，则流处理必须处理该数据库。相反，将两者分离，Kafka Connect将处理无法访问的数据库等。