Skip to content
Discussion options

You must be logged in to vote

The key inside your KeyValue<K,V> object and the Pulsar message key used for routing are separate in the Java client.

  • INLINE serializes both parts into the payload. It does not automatically copy the object's key into the message-key metadata.
  • SEPARATED serializes the object's key into the message-key metadata and puts only the value in the payload.

You can see both paths in TypedMessageBuilderImpl, v4.0.8 and its separated-key implementation.

Your first statement is correct if you use INLINE without setting a message key or ordering key: Key_Shared cannot group messages by a key that exists only inside the payload. However, INLINE itself does not prevent keyed routing. You can supply t…

Replies: 1 comment

Comment options

You must be logged in to vote
0 replies
Answer selected by kasparjarek
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
2 participants