sql >> データベース >  >> RDS >> Mysql

Kafkaは、AWSMSKを使用してAuroraからレコードを送信するためのセットアップを接続します

    いいえ。jsonレコードでスキーマを有効にできます。 JDBCソースはそれらを作成することができます テーブル情報に基づく

    value.converter=org.apache.kafka...JsonConverter 
    value.converter.schemas.enable=true
    

    スキーマレジストリを使用する場合は、kafkastore.bootstrap.serversを使用する必要があります .Zookeeperではなく、Kafkaアドレスを使用します。したがって、kafkastore.connection.urlを削除します

    ドキュメントをお読みください すべてのプロパティの説明について

    関係ない。スキーマトピックは、レジストリが最初に起動したときに作成されます

    はい(使用可能なJVMヒープスペースを無視します)。繰り返しますが、これはKafkaConnectのドキュメントで詳しく説明されています。

    スタンドアロンモードを使用して、最初に接続ワーカー構成を渡し、次に1つのコマンドで最大N個のコネクタプロパティを渡します

    分散モードを使用して、Kafka ConnectRESTAPIを使用します

    https://docs.confluent.io/current/connect/managing/configuring .html

    まず第一に、それはSqlite用であり、Mysql/Postgres用ではありません。クイックスタートファイルを使用する必要はありません。参照用にのみ存在します

    繰り返しますが、すべてのプロパティは十分に文書化されています

    https://docs.confluent.io /current/connect/kafka-connect-jdbc/index.html#connect-jdbc

    これをデバッグする方法の詳細は次のとおりです

    https://www.confluent.io/ blog / kafka-connect-deep-dive-jdbc-source-connector /

    前に述べたように、私は個人的に可能な場合はDebezium/CDCを使用することをお勧めします

    RDSオーロラ用Debeziumコネクタ



    1. MySQL SUM()が誤った合計を与える

    2. 行データを列に動的に変換するmysqlクエリ

    3. PDOエラー:SQLSTATE [HY000]:一般エラー:2031

    4. MySQLクロスサーバー選択クエリ