pulsar-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Apache Pulsar Slack" <apache.pulsar.sl...@gmail.com>
Subject Slack digest for #general - 2018-12-31
Date Mon, 31 Dec 2018 09:11:02 GMT
2018-12-30 18:01:46 UTC - Facundo Rodriguez: If I want to build a consumer via websocket I
have to produce via websocket? Because I build a producer using Pulsa client when I a consumer
user the Pulsar client works perfectly but when I want to consume from a ReactJS componen
via websocket the handshake returns 400 instead of 101
----
2018-12-30 21:09:27 UTC - Sijie Guo: &gt; If I want to build a consumer via websocket
I have to produce via websocket?

no. you don’t need to produce via websocket.

&gt;  the handshake returns 400 instead of 101

make sure you are using the right topic name
----
2018-12-31 00:37:20 UTC - Facundo Rodriguez: this is mi producer `producer = client.create_producer('<persistent://public/default/orderbook/pair>')`
and this is my consumer
```
TOPIC = '<ws://localhost:8080/ws/v2/consumer/persistent/public/default/orderbook/pair/suscription-1>'

async def orderbook_consumer():
    async with websockets.connect(TOPIC) as websocket:
        data = await websocket.recv()
        print(f"&lt; {data}")
```
----
2018-12-31 00:40:33 UTC - Sijie Guo: @Facundo Rodriguez ah it might be related encoding regarding
“ordering/pair”.

can you try ‘<persistent://public/default/orderbook_pair>’ (let try not use ‘/’
in the topic name)
----
2018-12-31 01:00:28 UTC - Facundo Rodriguez: It works! Thank you so much!!
----
2018-12-31 01:00:33 UTC - Facundo Rodriguez: An happy new year!
----
2018-12-31 01:00:48 UTC - Sijie Guo: Happy new year!
----
2018-12-31 07:09:41 UTC - Samuel Sun: Hi , one simple question, if there are two clusters
under one namespace, and create a topic under this namespace, this topic will be in which
cluster ?
----
Mime
View raw message