com.microsoft.azure.eventhubs.EventHubException: ошибка подключения прервана

Question

Я получаю сообщение об ошибке, при вызове метода ниже, он сбой в строке "eventHubClient.get().send(messageData)"

def sendEvent(message: String) = {
  val messageData = EventData.create(message.getBytes("UTF-8"))
  println(messageData)
  eventHubClient.get().send(messageData)
  System.out.println("Sent event: " + message + "\n")
}

Я получаю ошибку;

com.microsoft.azure.eventhubs.EventHubException: соединение прервано на com.microsoft.azure.eventhubs.impl.ExceptionUtil.toException (ExceptionUtil.java:58) на com.microsoft.azure.eventhubs.impl.MessagingFactory.onConnectionError (MessagingFactory.java:257)com.microsoft.azure.eventhubs.impl.ConnectionHandler.onTransportError (ConnectionHandler.java:105) в org.apache.qpid.proton.engine.BaseHandler.handle (BaseHandler.java:191) в org.apache.qpid.proton.engine.impl.EventImpl.dispatch (EventImpl.java:108) в org.apache.qpid.proton.reactor.impl.ReactorImpl.dispatch (ReactorImpl.java:324) в org.apache.qpid.proton.reactor.impl.ReactorImpl.process (ReactorImpl.java:291) по адресу com.microsoft.azure.eventhubs.impl.MessagingFactory $ RunReactor.run (MessagingFactory.java:483) по адресу java.util.concurrent.ThreadPoolExecutor.runWorker:o) (поток)на java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:624) в java.lang.Thread.run (Thread.java:748)