-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Support KeyValue Schema Use Null Key And Null Value #7139
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
cdd94ec to
c1e56ed
Compare
1f02836 to
25fcd02
Compare
|
/pulsarbot run-failure-checks |
| optional int32 chunk_id = 29; | ||
|
|
||
| // Indicate if the message key is set | ||
| optional bool null_key = 30 [default = false]; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It's better to use null_partition_key here since we have partition_key and ordering key in the proto. Use null_partition_key will be more accurate.
| // Indicate if the message payload value is set | ||
| optional bool null_value = 9 [ default = false ]; | ||
| // Indicate if the message key is set | ||
| optional bool null_key = 10 [ default = false]; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same as the above comment.
|
/pulsarbot run-failure-checks |
|
/pulsarbot run-failure-checks |
…te-update * 'website-update' of github.com:zeo1995/pulsar: (432 commits) Fixed ordering issue in KeyShared dispatcher when adding consumer (apache#7106) Fix Duplicated messages are sent to dead letter topic apache#6960 (apache#7021) [Issue 2793][Doc]--Update the TLS hostname verification for CPP and Python clients (apache#7162) [Doc]--set netty mex frame size (apache#7174) [Doc] Update for the maximum message size (apache#7171) Fixed KeyShared consumers getting stuck on delivery (apache#7105) [apache#6003][pulsar-functions] Possibility to add builtin Functions (apache#6895) [Issue 6921][pulsar-broker-common] Replaced "Paths.get(...).getParent()", because it's system dependent and uses '\' as path separator on Windows (apache#6992) Improve broker unit test CI (apache#7173) Fix typo in exception message (apache#7027) Support KeyValue Schema Use Null Key And Null Value (apache#7139) [Doc]--Update documents for support consumer priority level in failover mode (apache#7136) Add schema config to cpp and cgo docs. (apache#7137) [Doc]--Update for the maximum message size (apache#7160) [C++] Expose ZSTD and Snappy compression to C API (apache#7014) [pulsar-proxy] add proxyLogLevel into config file (apache#6948) Add multi-hosts example for bookkeeperMetadataServiceUri (apache#6998) support for termination of partitioned topic (apache#6126) Use pure-java Air-Compressor instead of JNI based libraries (apache#5390) [Issues 5709]remove the namespace checking (apache#5716) ... # Conflicts: # site2/website/scripts/split-swagger-by-version.js
|
This does not work as described here |
Fixes apache#4804 Thanks, @nlu90, work at apache#6384. ### Motivation Currently, the KeyValue schema doesn't handle `null` key and `null` value well.
Fixes apache#4804 Thanks, @nlu90, work at apache#6384. ### Motivation Currently, the KeyValue schema doesn't handle `null` key and `null` value well.
Fixes #4804
Thanks, @nlu90, work at #6384.
Motivation
Currently, the KeyValue schema doesn't handle
nullkey andnullvalue well.Modifications
Make the KeyValue schema support
nullkey andnullvalueVerifying this change
This change added tests and can be verified as follows:
Does this pull request potentially affect one of the following parts:
If
yeswas chosen, please highlight the changesDocumentation