我想写一个Kafka消费者使用protobuf格式的消息是在proto格式，我尝试了这个链接，但没有帮助，谁能建议什么。
ipakzgxi1#
为什么不尝试使用byte[]或json来代替protobuf呢？1:使用byte[]生成数据时，可以调用 com.google.protobuf.Parser<YourStruce> 从原始数据中轻松解析数据。2:使用json，方法 com.google.protobuf.util.JsonFormat.Parser.merge(String json, Message.Builder builder) 也会有帮助。
com.google.protobuf.Parser<YourStruce>
com.google.protobuf.util.JsonFormat.Parser.merge(String json, Message.Builder builder)
nhaq1z212#
查看以下链接，https://github.com/daniccan/httptokafkaprocessor这个项目包含一个kafka生产者，它将protobuf对象推入kafka。你可以用它作为参考来编写你自己的Kafka消费者。
2条答案
按热度按时间ipakzgxi1#
为什么不尝试使用byte[]或json来代替protobuf呢？
1:使用byte[]生成数据时，可以调用
com.google.protobuf.Parser<YourStruce>从原始数据中轻松解析数据。2:使用json，方法
com.google.protobuf.util.JsonFormat.Parser.merge(String json, Message.Builder builder)也会有帮助。nhaq1z212#
查看以下链接，
https://github.com/daniccan/httptokafkaprocessor
这个项目包含一个kafka生产者，它将protobuf对象推入kafka。你可以用它作为参考来编写你自己的Kafka消费者。