pulsar

Hi Hamza, I believe the serviceUrl is what you are looking for: <https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#application-properties.pulsar-client.spring.pulsar.client.service-url>

and for admin client, it's `spring.pulsar.administration.service-url` (<https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#application-properties.pulsar-administration.spring.pulsar.administration.service-url|docs>)

and the protocol for administrator and client both will be http?

```spring:
  pulsar:
    administrator:
      service-url: <pulsar://localhost:61402>
    client:
      service-url: <http://localhost:61376>```
Is this correct?

no it's not correct, the client uses pulsar protocol. (btw. For more secure communications, you should pulsar+ssl for that. https for admin.)

I will make sure the docs give a clear example how to set these.

<@U04MBHN8W3Y> this should help the ref docs in this area <https://github.com/spring-projects-experimental/spring-pulsar/pull/340/files>

It has been merged and hopefully these area make it clear for the next person…

<https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#reactive-pulsar-client>

<https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#pulsar-admin-client>

<https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#application-properties.pulsar-client.spring.pulsar.client.service-url>

<https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#application-properties.pulsar-administration.spring.pulsar.administration.service-url>

Hi <@U04MBHN8W3Y>,

&gt;  I am switching to pulsar and want to confirm if pulsar supports exchange based routing similar to rabbitmq.
Pulsar and Rabbit are quite different in this area and I am not sure what the replacement for this would be in Pulsar. I would ask this part of the question in <#C5Z4T36F7|> (leaving out any Spring Cloud Stream aspect).

For the Spring Cloud Stream (SCSt) part of the question,
It sounds like you are wanting to use the <https://docs.spring.io/spring-pulsar/docs/0.2.x/reference/html/#pulsar-binder|Spring Cloud Stream Binder for Apache Pulsar,> instead of the Rabbit binder.

Those properties you are currently using are binding-level consumer properties and are highly specific to Rabbit. They would be ignored or the application would not start if you attempted to replace the word “rabbit” w/ “pulsar”.
• Here are the <https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-rabbit.html#_rabbitmq_consumer_properties|Rabbit consumer props>.
• Here are the <https://github.com/spring-projects/spring-pulsar/blob/0.2.x/spring-pulsar-spring-cloud-stream-binder/src/main/java/org/springframework/pulsar/spring/cloud/stream/binder/properties/PulsarConsumerProperties.java|Pulsar consumer props.>
Please note that the SCSt Pulsar binder is in its early stages in comparison to the SCSt Rabbit binder. If there are things you would like to be added to the Pulsar binder OR if you find issues w/ it please report them on <https://github.com/spring-cloud/spring-cloud-stream>.

This is not what you are directly asking, but it is probably a good thing to be aware of solutions that exist to ease the move from RabbitMQ to Pulsar:
• <https://github.com/streamnative/aop>
• <https://github.com/datastax/starlight-for-rabbitmq>
cc: <@U03ENNB8HPC>

Also, I think you asked this question here because the question is related to Spring Pulsar and the Reactive client for Pulsar is used by Spring Pulsar and this is the closest channel you could find to post in. Is that correct?  I just want to be sure I am not missing something in your question that you may want to be knowing about the Reactive client.

<@U04MBHN8W3Y> If you can directly use the Pulsar binder, that would be the best approach rather than trying to use Rabbit binder over pulsar. Those properties you mentioned ^^ will not work with Pulsar the way it is right now.

Yes, I am using pulsar binder : <https://github.com/spring-projects/spring-pulsar/tree/0.2.x/spring-pulsar-spring-cloud-stream-binder>

But i want to understand what would be equivalent of exchangeType in pulsar?

I suggested that you ask the exact question in general channel but it looks like you just asked this same question there. I would instead,  leave out any SCS aspect and ask "what is the equivalent of rabbit exchange in pulsar?"

No.worries. I hope my reply did not seem rude,, that was not my intention. 

Once we understand the replacement for exchange in pulsar  then we can see how to do the same in the pulsar binder.

No not at all. Thanks for the help :slightly_smiling_face:

You may want to mention that your first post in the general channel is a repost and link to original so that we don't duplicate info. Its possible that christophe does not see the original post (here) and then takes time to answer and just get you the same info that we did here.

 context
• ordering required 
• have partitioning for throughput
• using pulsar client (non-reactive)
• listener threads are getting shared across internal queue in a blocking fashion 
• mostly io
ques: 
in order to have higher throughput i can increase listener threads so that internal queues processing do not block each others.
partitions and topics will increase and therefore there’s not end to it.

How can pulsar reactive client help with this?
i want high throughput with less number of thread.
how does it overcome native pulsar client <https://github.com/apache/pulsar/blob/5a59ab7768e11db6ed92dada78b398feca9e24fc/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java#L1152|listeners blocking behaviour>?
pipelining i am aware of but it seems conflicting with partitions

replied in <https://apache-pulsar.slack.com/archives/C5Z4T36F7/p1752764076361219?thread_ts=1752749962.223939&amp;cid=C5Z4T36F7>