[GitHub] [pulsar-client-python] xuehuanran opened a new issue, #46: The ArgumentError of the 'replication_clusters' in producer.send method in python pulsar.

[GitBox <gi...@apache.org>]

xuehuanran opened a new issue, #46:
URL: https://github.com/apache/pulsar-client-python/issues/46

   I want to use the geo-replication in python pulsar and my code is below.
   
   ```
   client = pulsar.Client("pulsar://localhost:6650")
   producer = client.create_producer("python_topic_00", schema=StringSchema())
   producer.send("Message0", replication_clusters=["cluster1", "cluster2"])
   ```
   
   The error message is :
   
   ```
   Traceback (most recent call last):
     File "tests/test_pulsar_producer.py", line 8, in <module>
       producer.send("Message0", replication_clusters=["cluster1", "cluster2"])
     File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pulsar/__init__.py", line 786, in send
       replication_clusters, disable_replication, event_timestamp)
     File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pulsar/__init__.py", line 879, in _build_msg
       mb.replication_clusters(replication_clusters)
   Boost.Python.ArgumentError: Python argument types in
       MessageBuilder.replication_clusters(MessageBuilder, list)
   did not match C++ signature:
       replication_clusters(pulsar::MessageBuilder {lvalue}, std::__1::vector<std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> >, std::__1::allocator<std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > > >)
   ```
   
   What is the correct data format of the replication_cluster argument.
   


-- 
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: commits-unsubscribe@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org