nlu90 commented on a change in pull request #11293:
URL: https://github.com/apache/pulsar/pull/11293#discussion_r678718264
##########
File path:
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/BaseContext.java
##########
@@ -194,11 +195,27 @@
void recordMetric(String metricName, double value);
/**
- * Get the pulsar client.
+ * Get the pre-configured pulsar client.
+ *
+ * You can use this client to access Pulsar cluster.
+ * The Function will be responsible for disposing this client.
*
* @return the instance of pulsar client
*/
default PulsarClient getPulsarClient() {
throw new UnsupportedOperationException("not implemented");
}
+
+ /**
+ * Get the pre-configured pulsar client builder.
+ *
+ * You can use this Builder to setup client to connect to the Pulsar
cluster.
+ * The Function will be responsible for disposing any PulsarClient created
by this builder.
+ *
+ * @return the instance of pulsar client builder.
+ */
+ default ClientBuilder getPulsarClientBuilder() {
Review comment:
working on it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
