Tidak. Anda dapat mengaktifkan skema di catatan json. Sumber JDBC dapat membuatnya untuk Anda berdasarkan informasi tabel
value.converter=org.apache.kafka...JsonConverter
value.converter.schemas.enable=true
Jika Anda ingin menggunakan Schema Registry, Anda harus menggunakan kafkastore.bootstrap.servers .dengan alamat Kafka, bukan Zookeeper. Jadi hapus kafkastore.connection.url
Harap baca dokumen untuk penjelasan semua properti
Tidak masalah. Topik skema dibuat saat Registry pertama kali dimulai
Ya (mengabaikan ruang tumpukan JVM yang tersedia). Sekali lagi, ini dirinci dalam dokumentasi Kafka Connect.
Menggunakan mode mandiri, pertama-tama Anda melewati konfigurasi pekerja koneksi, lalu hingga properti konektor N dalam satu perintah
Menggunakan mode terdistribusi, Anda menggunakan Kafka Connect REST API
https://docs.confluent.io/current/connect/managing/configuring .html
Pertama-tama, itu untuk Sqlite, bukan Mysql/Postgres. Anda tidak perlu menggunakan file quickstart, mereka hanya ada untuk referensi
Sekali lagi, semua properti didokumentasikan dengan baik
https://docs.confluent.io /current/connect/kafka-connect-jdbc/index.html#connect-jdbc
Berikut informasi selengkapnya tentang cara men-debug
https://www.confluent.io/ blog/kafka-connect-deep-dive-jdbc-source-connector/
Seperti yang dinyatakan sebelumnya, saya pribadi menyarankan menggunakan Debezium/CDC jika memungkinkan
Konektor Debezium untuk RDS Aurora
