我使用druid索引服务来摄取kafka数据,当我创建一个数据源时,它工作得很好。但是,当我添加另一个数据源时,没有要为第二个数据源分配的任务。我应该如何使所有数据源都能很好地工作?下面有两个数据源。但是运行任务都是关于“内部主页”数据源的,工作能力(cores-1)都是关于“内部主页”数据源的,请帮帮我。
tpxzln5u1#
我已经自己解决了这个问题,只需更改摄取json配置,segmentgranularity从分钟到小时设置,taskcount设置为等于kafka consumer的分区,replicas设置为1。
1条答案
按热度按时间tpxzln5u1#
我已经自己解决了这个问题,只需更改摄取json配置,segmentgranularity从分钟到小时设置,taskcount设置为等于kafka consumer的分区,replicas设置为1。