This message was deleted.
# generals
Slackbot
05/30/2023, 12:30 PMThis message was deleted.
e
Enrico Olivelli
05/30/2023, 12:30 PMthere is no API available out of the box
Enrico Olivelli
05/30/2023, 12:31 PMyou can JMS if you prefer and you have some APIs
Enrico Olivelli
05/30/2023, 12:31 PM(there is a JMS API for Pulsar)
Enrico Olivelli
05/30/2023, 12:32 PMbut I would implement it from scratch, it is easy, as you can set the name for a response topic in a message property
Enrico Olivelli
05/30/2023, 12:32 PMon the consumer you read the property and send the response to the address set by the producer
e
Evgeny
05/30/2023, 12:34 PMThat makes sense, but how do you know which partition will receive the response? I need to keep the connection open on only one of the partitions.
e
Enrico Olivelli
05/30/2023, 12:41 PMyou can target a specific parttion with a producer or a consumer
Enrico Olivelli
05/30/2023, 12:41 PMeach partition IS a non-partitioned topic as a matter of fact
Enrico Olivelli
05/30/2023, 12:41 PMso you can produce to public/default/mytopic-partition-1
Enrico Olivelli
05/30/2023, 12:42 PMthe same for consumers
Enrico Olivelli
05/30/2023, 12:42 PMon the producer you can implement a custom “Router” that forces the partition, as an alternative
e
Evgeny
05/30/2023, 12:44 PMSorry, just trying to understand, so producer can target specific partition of the topic consumer?
Evgeny
05/30/2023, 12:45 PMmight be asking stupid questions, trying to wrap my head around it
Evgeny
05/30/2023, 12:47 PMso I need Partition 1 to respond to P1 after request was sent from P1 to Partition 1
l
Lari Hotari
05/30/2023, 12:54 PMThere is a RPC library on top of Pulsar in https://github.com/streamnative/pulsar-recipes/tree/main/rpc . It seems experimental. I haven't used it.
👀 1
m
merlimat
05/30/2023, 4:43 PM@Evgeny It’s an actually supported library, it’s not experimental
👍 2
e
Evgeny
05/31/2023, 8:20 AMThank you all!