Wygląda na to, że jest to zachowanie oficjalnego łącznika MongoDB Kafka Source. Oto odpowiedź, którą otrzymałem na innym forum od Rossa Lawleya (programisty MongoDB):
Przed wersją 1.2.0 tylko jedno zadanie było obsługiwane przez łącznik ujścia.Łącznik źródłowy nadal obsługuje tylko jedno zadanie, ponieważ używa jednego kursora Zmień strumień. To wystarczy, aby obserwować i publikować zmiany w całym klastrze, w całej bazie danych lub w jednej kolekcji.
Podniosłem ten bilet:https://jira.mongodb.org/browse/KAFKA-121 Otrzymano następującą odpowiedź:Łącznik źródłowy zawsze wygeneruje tylko jedno zadanie. Jest to zgodne z projektem, ponieważ łącznik źródłowy jest wspierany przez strumień zmian. Strumienie zmian wewnętrznie wykorzystują te same dane, które są używane przez silnik replikacji i jako takie powinny być w stanie skalować się tak jak baza danych. Nie ma planów zezwalania na wiele kursorów, jednak jeśli uważasz, że nie spełnia to twoich wymagań, możesz skonfigurować wiele złączy, a każde z nich miałoby własny kursor strumienia zmian.
