我们需要使用jdbc连接器从rdbms读取数据，然后在将数据推送到kafka之前使用自定义加密。解密数据，然后将其推送到后续接收器。
为了实现这一点，我们是否需要提供以下自定义实现（jdbc连接器属性的一部分）：

"key.converter": "io.confluent.connect.avro.AvroConverter",    ==>"key.converter": "OurCustomeAvroConverter"

或
我们是否需要提供以下自定义实现（生产者配置属性的一部分）：

key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer ==> key.serializer = Custom Implementation

如果是的话 key.serializer 那么我们如何设置这个属性，以便jdbc连接器可以选择它呢？
谢谢，