如何将Flink连接到Druid?

问题描述

我正在尝试将Flink连接到Druid。

但是,我不知道该怎么做。

在此Flink documentation中,“ bootstrap.servers”设置为“ localhost:9092”。

这是否意味着我可以使用Apache Kafka ingestion直接连接,因为下面的样例主管规范设置了?

    "consumerProperties": {
      "bootstrap.servers": "localhost:9092"
    },

除了Flink之外,我还需要运行Kafka吗?还是应该做其他事情将Flink连接到Druid?

解决方法

您可以通过宁静https://github.com/druid-io/tranquility

将Flink连接到Druid