2020-08-14 11:36:42 UTC - Ravi Shah: Hi Team,

How can I implement kafka keyed partition type functionality with pulsar?
----
2020-08-14 17:14:09 UTC - Sijie Guo: 
<https://github.com/apache/pulsar/blob/master/pulsar-common/generate_protobuf_docker.sh>
----
2020-08-14 17:15:14 UTC - Sijie Guo: You can sepcify a key for a message. The 
message will be routed based on the key.

If you want to customize the routing algorithm, you can write your own 
MessageRouter.
----

Reply via email to