用于活动中心的kafkacat

Question

嗨，我试着在我的一个azure虚拟机中使用kafkacat检查到eventhub的连接，我给出了以下参数(填写我的hab名称和所有)：

 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

但我一直收到：% ERROR:无法获取元数据: Local: Broker传输失败

这里会出什么问题呢？我是否必须创建一个主题和SAS身份验证并获取他的密钥？

Answer 1

使用kafka协议的eventhub的端口为9093。

https://docs.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