いいえ。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を使用することをお勧めします