可以使用kafka Connect value Conveter(JSONCONVERTER(转换GPB？
我使用的是Kafka Connect作为接收器，并将所有主题消息(GPB(写入数据库
我使用默认的jsonconverter作为value.valueconverter。
如果没有，我可以使用用于此对象的Deserializer类，还是我需要编写其他自定义类？您能分享一些相同的示例
no，jsonConverter期望严格形成的JSON，协议缓冲区(我认为这是您所说的GPB？(是二进制记录，需要适当的转换器。
幸运的是，社区在这里有一个可用：https：//github.com/blueapron/kafka-connect-protobuf-converter/blob/blob/master/master/readme.md