[pulsar] 09/12: use keyword argument to create pulsar_client (#11080)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit d58143bc65acc2bb108cfa728b2376dde3dd4de8
Author: Rui Fu <fr...@users.noreply.github.com>
AuthorDate: Fri Jun 25 02:19:04 2021 +0800

    use keyword argument to create pulsar_client (#11080)
    
    
    (cherry picked from commit eafe7dd56dfbaafb99c66db1155486fdc90ebbc3)
---
 pulsar-functions/instance/src/main/python/python_instance_main.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/pulsar-functions/instance/src/main/python/python_instance_main.py b/pulsar-functions/instance/src/main/python/python_instance_main.py
index 8c5bf8a..322d728 100644
--- a/pulsar-functions/instance/src/main/python/python_instance_main.py
+++ b/pulsar-functions/instance/src/main/python/python_instance_main.py
@@ -158,7 +158,10 @@ def main():
     tls_allow_insecure_connection = True
   if args.tls_trust_cert_path:
      tls_trust_cert_path =  args.tls_trust_cert_path
-  pulsar_client = pulsar.Client(args.pulsar_serviceurl, authentication, 30, 1, 1, 50000, None, use_tls, tls_trust_cert_path, tls_allow_insecure_connection)
+  pulsar_client = pulsar.Client(args.pulsar_serviceurl, authentication=authentication, operation_timeout_seconds=30,
+                                io_threads=1, message_listener_threads=1, concurrent_lookup_requests=50000,
+                                log_conf_file_path=None, use_tls=use_tls, tls_trust_certs_file_path=tls_trust_cert_path,
+                                tls_allow_insecure_connection=tls_allow_insecure_connection)
 
   state_storage_serviceurl = None
   if args.state_storage_serviceurl is not None: