Sometimes it can be useful to send something more complex than a string as the key of the message. However, early on Pulsar chose to make String the only way to send a key, and this permeates throughout the code, so we can't very well change it now.
This patch adds rudimentary byte[] key support. If a user adds a byte[] key, the byte[] is base64 encoded and stored in the normal key field. We also send a flag to denote that it is base64 encoded, so the receiving end knows to decode it correctly. There's no schema or anything attached to this. Any SerDe has to be handled manually by the client. [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2612 ] This message was relayed via gitbox.apache.org for [email protected]
