azure - 用于事件中心的 kafkacat

Question

嗨，我尝试在我的 Azure 虚拟机之一中使用 kafkacat 检查与 eventhub 的连接我给出了以下参数(填写我的居住地名称和全部):

 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

但我不断收到:％错误:无法获取元数据:本地:代理传输失败

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

Answer 1

kafka协议(protocol)的eventhub端口是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