in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java [103:114]
public void serialize(KeySharedPolicy keySharedPolicy, JsonGenerator gen, SerializerProvider serializers)
throws IOException {
if (keySharedPolicy instanceof KeySharedPolicy.KeySharedPolicySticky) {
gen.writeString("STICKY");
}
else if (keySharedPolicy instanceof KeySharedPolicy.KeySharedPolicyAutoSplit) {
gen.writeString("AUTO_SPLIT");
}
else {
gen.writeString(keySharedPolicy.getClass().getName());
}
}