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!