Mongo-source không hỗ trợ task.max> 1. Ngay cả khi bạn đặt nó lớn hơn 1 chỉ một tác vụ sẽ kéo dữ liệu từ mongo sang Kafka.
Số lượng tác vụ được tạo tùy thuộc vào trình kết nối cụ thể. Hàm List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (sẽ được ghi đè trong quá trình triển khai trình kết nối của bạn) trả về danh sách, kích thước xác định số lượng Nhiệm vụ. Nếu bạn kiểm tra trình kết nối nguồn mongo-kafka, bạn sẽ thấy rằng đó là singletonList.
