[GitHub] jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis

jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218900232 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.jav

[GitHub] jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis

jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218900232 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.jav

[GitHub] jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis

jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218606215 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.jav

[GitHub] jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis

jerrypeng commented on a change in pull request #2605: implement topic routing on a per record basis URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218606215 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.jav