正在寻找一个库或算法，该库或算法以 protobuf 格式实现消息的序列化，并使用从融合模式注册表中检索到的模式版本。我使用 php-rdkafka 扩展向 Kafka 主题发送消息。
消息的格式记录在这里
对于 protobuf - 它是一个字节数组
magic-byte, schema-id, message-indexes, protobuf-payload
您可以在此处找到为 Avro 生成相同线路格式的源代码，一旦您拥有任何 protobuf 对象的原始字节数组，您就需要执行非常相似的操作。
而那个库就是使用php-rdkafka-examples repo
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句