HDInsight Storm 无法使用示例应用程序读取/写入 EventHub答案

【问题标题】：HDInsight Storm cannot read/write to EventHubs using sample applicationHDInsight Storm 无法使用示例应用程序读取/写入 EventHub
【发布时间】：2017-02-28 09:35:36
【问题描述】：

我正在尝试实现给定here 的示例 EventHub 应用程序，但它给了我错误。我已经按照文档中给出的完全相同的步骤进行操作。我使用的是 HDInsight 3.5、Storm 1.0.1.2.5.4.0-121

这是 EventHubReader 的一个，从 Storm UI 中可以看到。

com.microsoft.eventhubs.client.EventHubException: org.apache.qpid.amqp_1_0.client.ConnectionErrorException: An AMQP error occurred (condition='amqp:unauthorized-access'). TrackingId:53ca4652535f423e5f0049dc08ef9_G22, SystemTracker:gateway2, Timestamp:2/28/2017 7:51:21 AM
at com.microsoft.eventhubs.client.EventHubReceiver.ensureReceiverCreated(EventHubReceiver.java:112) ~[stormjar.jar:?]
at com.microsoft.eventhubs.client.EventHubReceiver.<init>(EventHubReceiver.java:65) ~[stormjar.jar:?]
at com.microsoft.eventhubs.client.EventHubConsumerGroup.createReceiver(EventHubConsumerGroup.java:56) ~[stormjar.jar:?]
at com.microsoft.eventhubs.client.ResilientEventHubReceiver.initialize(ResilientEventHubReceiver.java:63) ~[stormjar.jar:?]
at org.apache.storm.eventhubs.spout.EventHubReceiverImpl.open(EventHubReceiverImpl.java:74) ~[stormjar.jar:?]
...
AMQP error occurred (condition='amqp:unauthorized-access'). TrackingId:53ca4652535f423e825f0049dc08eff9_G22, SystemTracker:gateway2, Timestamp:2/28/2017 7:51:21 AM
at org.apache.qpid.amqp_1_0.client.Receiver.<init>(Receiver.java:223) ~[stormjar.jar:?]
at org.apache.qpid.amqp_1_0.client.Session.createReceiver(Session.java:281) ~[stormjar.jar:?]  ... 11 more

EventHubWriter：

com.microsoft.eventhubs.client.EventHubException: An error occurred while sending data.
at com.microsoft.eventhubs.client.EventHubSender.sendCore(EventHubSender.java:93) ~[stormjar.jar:?] 
Caused by: org.apache.qpid.amqp_1_0.client.Sender$SenderCreationException: Peer did not create remote endpoint for link, target: my-event-hub
at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:191) ~[stormjar.jar:?]

pom.xml

<properties>
 <storm.version>1.0.1</storm.version>
 <hadoop.version>2.7.3</hadoop.version>
</properties>
...
 <dependency>
   <groupId>com.microsoft</groupId>
   <artifactId>eventhubs</artifactId>
   <version>1.0.2</version>
 </dependency>

我已确保在我的 EventHubs.properties 文件中 eventhub 连接命名空间和策略键是正确的。我还打开了 .jar 工件并确保包含 EventHub 类。

有人知道如何让它工作吗？

【问题讨论】：

标签： java azure apache-storm azure-hdinsight azure-eventhub