apache / apache/pulsar-client-python

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

未关闭
#46 3 条评论 0 个 reaction 已指派 1 人 已被 @BewareMyPower 认领 在 GitHub 查看
主要语言
Python
星标
75
派生
53
PR 合并指标
30 天内没有已合并 PR

描述

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.

贡献指南

打开贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。