kafkacat for event hub

Question

hi I tried to check connection to eventhub using kafkacat in one of my VM in azure I gave the following parametrs(fill my hab name and all):

 kafkacat \
-b <your-hub-name>.servicebus.windows.net:9092 \
-X security.protocol=sasl_ssl \
-X sasl.mechanism=PLAIN \
-X sasl.username='$ConnectionString' \
-X sasl.password='Endpoint=sb://<your-hub-name>.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=<primary-key>' \
-L

but I keep getting: % ERROR: Failed to acquire metadata: Local: Broker transport failure

what can go wrong here ? do I have to create a topic and SAS authentication and take his keys?

Answer 1

The port of eventhub with kafka protocol is 9093.

https://learn.microsoft.com/en-us/azure/event-hubs/event-hubs-kafka-connect-tutorial

bootstrap.servers={YOUR.EVENTHUBS.FQDN}:9093 # e.g. namespace.servicebus.windows.net:9093