我已经研究了合流kafka流wordcount和异常检测示例。在这些示例中，结果被写入主题。相反，我如何通过rest或其他方式轻松快速地将结果保存到远程数据库中。汇合台有什么构造吗
代码示例：//发送远程数据库而不是代码
wordcounts.tostream（）.to（“streams wordcount output”，produced.with（stringserde，lonserde））；
我已经研究了合流kafka流wordcount和异常检测示例。在这些示例中，结果被写入主题。相反，我如何通过rest或其他方式轻松快速地将结果保存到远程数据库中。汇合台有什么构造吗
代码示例：//发送远程数据库而不是代码
wordcounts.tostream（）.to（“streams wordcount output”，produced.with（stringserde，lonserde））；
1条答案
按热度按时间csga3l581#
这里通常的模式是将流处理的结果写入kafka主题，然后使用kafka connect将该主题流式传输到要将数据持久化到的任何位置。kafka connect是apache kafka的一部分，有许多连接器，包括
kafka-connect-jdbc用于向（或从）数据库写入数据。如果直接从streams应用程序写入数据库，则不必要地将处理和存储捆绑在一起。如果数据库脱机或无法访问，则流处理必须处理该问题。相反，将两者解耦，kafka connect将处理无法访问的数据库等。