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

Kafkaシンクコネクタ:再起動後もタスクが割り当てられていません

    私はこの問題に直面しました。 SinkTaskまたはSourceTaskを開始するためのリソースが少ない場合、これが発生する可能性があります。

    ワーカーに割り当てられたメモリは、少し時間がかかる場合があります。デフォルトでは、ワーカーには250MBが割り当てられます。これを増やしてください。以下は、分散モードで実行されているワーカーに2GBのメモリを割り当てる例です。

    KAFKA_HEAP_OPTS ="-Xmx2G" sh $ KAFKA_SERVICE_HOME / connect-distributed $ KAFKA_CONFIG_HOME / connect-avro-distributed.properties




    1. Grailsドキュメントのカスタムイベントリスナーの例

    2. MongoDB {aggregation$match}と{find}の速度

    3. javaアプリケーションを介してmongolabで作成されたmongodbを接続する

    4. mongodbのドキュメントから1つまたは2つのフィールドのみを削除するにはどうすればよいですか?