java - 使用 protobuf 创建 kafka 消费者

Question

我想使用protobuf格式编写一个kafka消费者，因为消息是proto格式的，我已经尝试过这个link但没有帮助，任何人都可以提出任何建议。

Answer 1

查看以下链接，

https://github.com/daniccan/HttpToKafkaProcessor

该项目包含一个 Kafka Producer，它将 protobuf 对象推送到 Kafka 中。您可以以此为引用来编写自己的Kafka Consumer。