У нас есть требование использовать JDBC Connector для чтения данных из RDBMS, а затем использовать наше настраиваемое шифрование перед отправкой данных в Kafka. И расшифровывает данные на выходе, а затем отправляет их в последующие приемники.
Чтобы добиться этого, нужно ли нам предоставить пользовательскую реализацию следующего (часть свойств коннектора JDBC):
"key.converter": "io.confluent.connect.avro.AvroConverter", ==>"key.converter": "OurCustomeAvroConverter"
OR
нужно ли нам предоставлять пользовательскую реализацию следующего (часть свойств конфигурации производителя):
key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer ==> key.serializer = Custom Implementation
Если это key.serializer, то как мы можем установить это свойство, чтобы оно могло быть выбрано соединителем JDBC?
Спасибо,
