zdroj Mongo nepodporuje úlohy.max> 1. I když nastavíte hodnotu větší než 1, pouze jedna úkolem bude vytáhnout data z mongo do Kafky.
Počet vytvořených úloh závisí na konkrétním konektoru. Funkce List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (který by měl být během implementace vašeho konektoru přepsán) vraťte seznam, jehož velikost určuje počet úkolů. Pokud zaškrtnete zdrojový konektor mongo-kafka, uvidíte, že je to singletonList.