MongoDB
 sql >> база данни >  >> NoSQL >> MongoDB

Може ли kafka да се свърже - изходният код на mongo се изпълнява като клъстер (max.tasks> 1)

Mongo-source не поддържа tasks.max> 1. Дори и да го зададете по-голямо от 1 само един задачата ще бъде изтегляне на данни от mongo към Kafka.

Колко задачи се създават зависи от конкретен конектор. Функция List<Map<String, String>> Connector::taskConfigs(int maxTasks) , (което трябва да бъде отменено по време на внедряването на вашия конектор) връща списъка, чийто размер определя броя на задачите. Ако поставите отметка на конектора източник mongo-kafka, ще видите, че той е singletonList.

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




  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Повторно използване на връзки към база данни с функции на Azure с помощта на Javascript

  2. Как да агрегирам вложен масив за търсене в mongoose?

  3. Как да извлека цялата стойност на вградения документ с помощта на официалния C# драйвер за MongoDB?

  4. Изпълнения на MongoDB - колко бази данни, колекции?

  5. Как мога да сортирам резултатите от заявката на MongoDB по размер на вътрешния масив?