apache-kafka - 为什么德鲁伊的kafka摄取服务不能有2个数据源

Question

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

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

Answer 1

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