This message was deleted.

This message was deleted.

This message was deleted.

Hi :) I am using the latest version of AOP on pulsar 2.10 with JWT authentication Is it possible to configure aop listener for using jwt and use it? Thanks

Hi, I already have a running, working pulsar cluster, and trying to connect to it using AOP. I’ve downloaded the .nar file, and copied it to all the pulsar brokers to the path ./protocols. Accordingly, I’ve added the following configuration to the broker.conf file of each broker: messagingProtocols=amqp protocolHandlerDirectory=./protocols amqpListeners=amqp://127.0.0.1:5672 I restarted the brokers, and using netstat -tulpn | grep java, I can see that port 5672 is listening. I’ve created a namespace for a rabbitmq VHost using the following CLI command: pulsar-admin namespaces create -b 1 public/vhost1 Now I want to connect to the pulsar cluster using an AMQP client. I wrote the following code in Python using the rabbitmq pika library: import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host=‘host1’, port=5672, virtual_host=‘vhost1’)) Running the code gives me the following error: pika.exceptions.IncompatibleProtocolError: StreamLostError: (‘Transport indicated EOF’,) Can anyone help me to figure out why this error occurs, and how to resolve it? Thanks!

Hi @here ! I read that AoP needs to be bound to a tenant (amqpTenant config param) and "A Vhost is backed by a namespace which can only have one bundle. You need to create a namespace in advance for the Vhost." So if I understand correctly, AoP is tied to a single tenant and the namespace is determined by the vhost specified by the client. Is there any way to use AoP with multi tenants on a same Pulsar instance please?