actually, it seems built-in `ProtobufSchema` couldn't deserialize `Function.Assignment` so, it seems it will require to add custom-schema and also, for deleted keys if topic is not compacted yet then consumer can consume message with empty-payload where consumer doesn't need to deserialize and AssignmentManager can directly delete assignment without deserializing message. so, i think keeping raw byte[] might be better choice.?
[ Full content available at: https://github.com/apache/incubator-pulsar/pull/2549 ] This message was relayed via gitbox.apache.org for [email protected]
