如何将 JDBC 连接器与自定义加密一起使用答案

【问题标题】：How to use JDBC connector with Customized Encryption如何将 JDBC 连接器与自定义加密一起使用
【发布时间】：2018-04-09 23:49:06
【问题描述】：

我们需要使用 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 连接器拾取？

谢谢，

【问题讨论】：

【解决方案1】：

如果您使用 Kafka 连接 JDBC 连接器将数据从 DBMS 推送到 kafka，则官方 Kafka 连接文档说要使用 key.convertor 和 value.convertor 属性。

【讨论】：