1

我使用 druid 索引服务来摄取 kafka 数据,当我创建一个数据源时,它运行良好。但是当我添加另一个数据源时,没有为第二个数据源分配任务。我应该如何使所有数据源都能正常工作?下面有 2 个数据源。

在此处输入图像描述

但是运行任务都是关于“inhouse_homepage”数据源的。工作容量(cores - 1)都是关于“inhouse_homepage”数据源的。请帮帮我。

在此处输入图像描述

4

1 回答 1

0

我自己解决了这个问题,只是为了改变摄取json配置,segmentGranularity从MINUTE设置为HOUR,taskCount设置为kafka消费者的分区,replicas设置为1。

于 2018-05-13T02:34:34.033 回答