Не. Можете да активирате схеми в json записи. JDBC източник може да ги създаде вместо вас въз основа на информацията в таблицата
value.converter=org.apache.kafka...JsonConverter
value.converter.schemas.enable=true
Ако искате да използвате Schema Registry, трябва да използвате kafkastore.bootstrap.servers
.с адреса на Кафка, а не на Zookeeper. Така че премахнете kafkastore.connection.url
Моля, прочетете документите за обяснения на всички свойства
Няма значение. Темата за схемите се създава, когато системният регистър стартира за първи път
Да (като се игнорира наличното пространство на JVM heap). Отново, това е подробно описано в документацията на Kafka Connect.
Използвайки самостоятелен режим, първо предавате конфигурацията на свързващия работник, след това до N свойства на конектора с една команда
Използвайки разпределения режим, използвате Kafka Connect REST API
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, където е възможно
Debezium конектор за RDS Aurora