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

複数のタスクが機能しない分散型公式MongodbKafkaソースコネクタ

    これは、公式のMongoDB KafkaSourceConnectorの動作のようです。これは、Ross Lawley(MongoDB開発者)から別のフォーラムで得た答えです:

    1.2.0より前は、シンクコネクタでサポートされていたタスクは1つだけでした。ソースコネクタは、1つの変更ストリームカーソルを使用するため、1つのタスクしかサポートしていません。これは、クラスター全体、データベース全体、または単一のコレクションに至るまでの変更を監視および公開するのに十分です。

    このチケットを調達しました: https://jira.mongodb.org/browse/KAFKA-121 次の応答があります:ソースコネクタは単一のタスクのみを生成します。これは、ソースコネクタが変更ストリームによってサポートされているため、仕様によるものです。変更ストリームは、レプリケーションエンジンで使用されるものと同じデータを内部的に使用するため、データベースと同じようにスケーリングできる必要があります。複数のカーソルを許可する予定はありませんが、これが要件を満たしていない場合は、次のことができます。複数のコネクタを設定すると、それぞれに独自の変更ストリームカーソルがあります。




    1. mongodbシェルクエリでGUIDを使用するにはどうすればよいですか

    2. レスキュー:接続が拒否されました-localhost:6379でRedisに接続できません

    3. Django-Mongodbリストフィールドを持つNonrel

    4. MongoDB Java API:com.mongodb.DBCollection.Save()とcom.mongodb.DBCollection.Insert()の違いは?