sql >> Databasteknik >  >> NoSQL >> MongoDB

Kan kafka ansluta - mongo-källa körs som kluster (max.tasks> 1)

Mongo-källa stöder inte tasks.max> 1. Även om du ställer in det större än 1 bara ett uppgiften kommer att dra data från mongo till Kafka.

Hur många uppgifter som skapas beror på den specifika kontakten. Funktion List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (som bör åsidosättas under implementeringen av din anslutning) returnera listan, vilken storlek bestämmer antalet uppgifter. Om du kontrollerar mongo-kafka källkontakt kommer du att se att det är singletonList.

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




  1. Prestandaökning genom att använda bulkinserts jämfört med vanliga inserts i MongoDB

  2. MongoDB $dateFromString

  3. Hur man $ställer sub-sub-array-objekt i MongoDB

  4. Mongo-skal som ger ut felet Flera förekomster av alternativ