我已经部署了kafka connect elasticsearch。connect distributed正在运行汇合3.1.2(作为一个组进行操作，共4台设备。）我已经放弃了 tasks.max=4 ，但我不知道为什么我只得到一个任务。
tasks.max=4
ax6ht2ek1#
分布式模式下的kafka connect将创建等于（a）tasks.max和（b）要导出的分区总数的最小值的接收器任务。您要导出多少个主题/分区到elasticsearch？
1条答案
按热度按时间ax6ht2ek1#
分布式模式下的kafka connect将创建等于（a）tasks.max和（b）要导出的分区总数的最小值的接收器任务。
您要导出多少个主题/分区到elasticsearch？