This message was deleted.

Maybe @Christophe Bornet could help here

@Hamza Azam since you are switching to Pulsar, you can use the native Sprint + Pulsar integration. See https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/ Here is the Sprint Cloud Stream Binder for Apache Pulsar: https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#pulsar-binder The concepts in Pulsar are different from RabbitMQ. It might be worth checking how to shift to use native Pulsar binder. However you want to stick to the AMQP protocol, Pulsar also have a native protocol handler for AMQP that is compatible with AMQP 0.9.1 (https://github.com/streamnative/aop). Happy to discuss more about what do you want to achieve and recommend the best solution for you.