如何使用模式 ID 序列化 protobuf 消息
How to serialize protobuf message with schema id
正在寻找一种库或算法，它以 protobuf 格式实现消息的序列化，其中的模式版本是从汇合模式注册表中检索到的。我使用 php-rdkafka 扩展来向 Kafka 主题发送消息。
消息的格式是documented here
对于 protobuf - 它是
的字节数组
magic-byte, schema-id, message-indexes, protobuf-payload
您可以使用 Confluent Registry 找到为 Avro 生成相同 wire-format 的源代码 here / here，一旦您拥有任何 protobuf 对象的原始字节数组，您就需要做一些非常相似的事情.
php-rdkafka-examples repo
使用的是那个库
正在寻找一种库或算法，它以 protobuf 格式实现消息的序列化，其中的模式版本是从汇合模式注册表中检索到的。我使用 php-rdkafka 扩展来向 Kafka 主题发送消息。
消息的格式是documented here
对于 protobuf - 它是
的字节数组magic-byte, schema-id, message-indexes, protobuf-payload
您可以使用 Confluent Registry 找到为 Avro 生成相同 wire-format 的源代码 here / here，一旦您拥有任何 protobuf 对象的原始字节数组，您就需要做一些非常相似的事情.
php-rdkafka-examples repo
使用的是那个库