apache / apache/pulsar-client-python

The ArgumentError of the 'replication_clusters' in producer.send method in python pulsar.

Đang mở
#46 3 bình luận 0 reaction 1 người được giao Được @BewareMyPower nhận Xem trên GitHub
Ngôn ngữ chính
Python
Star
75
Fork
53
Chỉ số merge pull request
Không có pull request nào được merge trong 30 ngày

Mô tả

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
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::allocator >, std::__1::allocator, std::__1::allocator > > >)
```

What is the correct data format of the replication_cluster argument.

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Đánh giá

Issue này chưa được đánh giá.

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.