создать потребительский кафка с протобуфом

Question

Я хочу написать потребителя kafka, используя формат protobuf, так как сообщение в формате proto, я пробовал эту ссылку , но безрезультатно, кто-нибудь может что-нибудь подсказать.

Answer 1

Проверьте следующую ссылку,

https://github.com/daniccan/HttpToKafkaProcessor

Этот проект содержит Kafka Producer, который помещает объект protobuf в Kafka.Вы можете использовать это как ссылку для написания своего собственного Kafka Consumer.

Answer 2

Почему бы не попробовать использовать byte [] или json вместо protobuf?
1: Используя byte [], когда вы создаете данные, вы можете вызвать com.google.protobuf.Parser<YourStruce> для первоначального анализа ваших данных.

2: Используя json, метод com.google.protobuf.util.JsonFormat.Parser.merge(String json, Message.Builder builder) также может быть полезен.