apache / apache/pulsar-client-python

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

Abierto
#46 3 comentarios 0 reacciones 1 asignado Reclamado por @BewareMyPower Ver en GitHub
Lenguaje dominante
Python
Estrellas
75
Forks
53
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

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.

Guía de contribución

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.