sql >> Base de Datos >  >> NoSQL >> MongoDB

¿Se puede conectar kafka:la fuente mongo se ejecuta como clúster (max.tasks> 1)

Mongo-fuente no es compatible con tasks.max> 1. Incluso si lo configura como mayor que 1, solo uno la tarea extraerá datos de mongo a Kafka.

La cantidad de tareas que se crean depende del conector en particular. Función List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (que debe anularse durante la implementación de su conector) devuelva la lista, cuyo tamaño determina el número de tareas. Si verifica el conector fuente mongo-kafka, verá que es singletonList.

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