@srkukarni @sijie This Example should be using
https://github.com/apache/pulsar/blob/master/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/WordCountFunction.java https://docs.oracle.com/javase/8/docs/api/java/util/function/Consumer.html [ Full content available at: https://github.com/apache/pulsar/issues/2695 ] This message was relayed via gitbox.apache.org for [email protected]
