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
i
Ido Hirsh
04/20/2023, 9:36 AM
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!