sql >> データベース >  >> NoSQL >> MongoDB

kafka接続できます-mongoソースをクラスターとして実行します(max.tasks> 1)

    Mongo-source tasks.max>1をサポートしていません。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. Macのmongodbのログファイルはどこにありますか

    2. JSONクエリ条件をMongoDB/Mongoose操作に変換します

    3. Node.js Mongooseを使用してドキュメントを削除するにはどうすればよいですか?

    4. レプリカSetmongodocker-compose