MongoDB
 sql >> Database >  >> NoSQL >> MongoDB

Può kafka connettersi - sorgente mongo eseguita come cluster (max.tasks> 1)

Mongo-source non supporta task.max> 1. Anche se lo imposti maggiore di 1, solo uno l'attività estrarrà i dati da mongo a Kafka.

Il numero di attività create dipende dal connettore particolare. Funzione List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (che dovrebbe essere sovrascritto durante l'implementazione del tuo connettore) restituisce l'elenco, la cui dimensione determina il numero di attività. Se controlli il connettore di origine mongo-kafka vedrai che è singletonList.

https://github.com/mongodb/mongo-kafka/blob/master/src/main/java/com/mongodb/kafka/connect/MongoSourceConnector.java#L47