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. ----