Kafka连接值转换器（jsonconverter）可以用来转换gpb吗？
我使用kafkaconnect作为接收器，并将所有主题消息（gpb）写入数据库
我在属性文件的value.converter字段中使用默认的jsonconverter作为valueconverter，这可以用来转换gpb对象吗？
如果没有，我可以使用反序列化器类来反序列化这个对象，或者我需要写一些其他自定义类？你能分享一些同样的例子吗
Kafka连接值转换器（jsonconverter）可以用来转换gpb吗？
我使用kafkaconnect作为接收器，并将所有主题消息（gpb）写入数据库
我在属性文件的value.converter字段中使用默认的jsonconverter作为valueconverter，这可以用来转换gpb对象吗？
如果没有，我可以使用反序列化器类来反序列化这个对象，或者我需要写一些其他自定义类？你能分享一些同样的例子吗
1条答案
按热度按时间3lxsmp7m1#
不，jsonconverter需要严格格式化的json，协议缓冲区（我假设这就是你所说的gpb？）是二进制记录，需要一个合适的转换器。
幸运的是，社区在这里有一个：https://github.com/blueapron/kafka-connect-protobuf-converter/blob/master/readme.md