为什么kafka connect分布式模式总是只分配一个任务?
Why is kafka connect distributed mode always assigned only one task?
我部署了kafka connect elasticsearch
Connect distributed 是 运行 confluent 3.1.2。
(作为一个group.id共4台设备运行。)
我给了tasks.max=4
,但不知道为什么只给了一个任务
分布式模式下的 Kafka Connect 将创建等于 (a) tasks.max 和 (b) 要导出的分区总数中的最小值的接收器任务。
您要导出多少 topic/partitions 到 elasticsearch?
我部署了kafka connect elasticsearch
Connect distributed 是 运行 confluent 3.1.2。 (作为一个group.id共4台设备运行。)
我给了tasks.max=4
,但不知道为什么只给了一个任务
分布式模式下的 Kafka Connect 将创建等于 (a) tasks.max 和 (b) 要导出的分区总数中的最小值的接收器任务。
您要导出多少 topic/partitions 到 elasticsearch?