【发布时间】:2018-08-21 12:03:23
【问题描述】:
我使用Kafka Streams处理实时数据,在Kafka Streams任务中,我需要访问MySQL查询数据,并且需要调用另一个restful服务。
所有操作都是同步的。
恐怕同步调用会降低流任务的处理能力。
这是一个好习惯吗?或者有什么好主意吗?
【问题讨论】:
-
这取决于您要实现的目标以及数据库级别需要哪些操作,但是我建议您查看 Kafka JDBC 连接器,以便您可以将数据从 MySQL 流式传输到 Kafka 和然后用 Kafka Streams 做任何你想做的事情。
-
@GiorgosMyrianthous 我编辑问题以清楚地描述我的问题,非常感谢。
-
MySQL查询到的数据需要做什么?
-
对于一些旧系统,它的数据存储在MySQL中。我需要查询 MySQL 的一些配置等等。
-
如前所述:推荐使用 Kafka Connect 将数据加载到主题中,并将数据作为
KTable(或者可能是GlobalKTable)读取到您的应用程序中。您可以通过连接进行查找。
标签: apache-kafka bigdata streaming apache-kafka-streams