Mongo-source tidak mendukung task.max> 1. Bahkan jika Anda menyetelnya lebih dari 1 hanya satu tugas akan menarik data dari mongo ke Kafka.
Berapa banyak tugas yang dibuat tergantung pada konektor tertentu. Fungsi List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (yang harus diganti selama implementasi konektor Anda) mengembalikan daftar, yang ukurannya menentukan jumlah Tugas. Jika Anda memeriksa konektor sumber mongo-kafka, Anda akan melihat, bahwa itu adalah singletonList.
