Sembra che questo sia il comportamento di Official MongoDB Kafka Source Connector. Questa è la risposta che ho ricevuto su un altro forum da Ross Lawley (sviluppatore MongoDB):
Prima della 1.2.0 solo una singola attività era supportata dal connettore sink. Il connettore di origine supporta ancora solo una singola attività, perché utilizza un singolo cursore del flusso di modifiche. Questo è sufficiente per visualizzare e pubblicare le modifiche a livello di cluster, database o fino a una singola raccolta.
Ho sollevato questo ticket:https://jira.mongodb.org/browse/KAFKA-121 Ho ottenuto la seguente risposta:Il connettore di origine produrrà sempre e solo una singola attività. Questo è in base alla progettazione poiché il connettore di origine è supportato da un flusso di modifiche. I flussi di modifiche utilizzano internamente gli stessi dati utilizzati dal motore di replica e in quanto tali dovrebbero essere in grado di scalare come fa il database. Non ci sono piani per consentire più cursori, tuttavia, se ritieni che ciò non soddisfi i tuoi requisiti, puoi configurare più connettori e ciascuno avrà il proprio cursore del flusso di modifiche.
