PutAzureEventHub throws TimeoutException

["Sergio M." <si...@hotmail.com>]

We use the processor PutAzureEventHub (version 1.11.4) to insert messages. When it starts, it works fine. After a while, it returns this error:

java.util.concurrent.CompletionException: com.microsoft.azure.eventhubs.TimeoutException: Entity(***): Send operation timed out at 2021-02-26T06:59:45.382-03:00[America/Argentina/Buenos_Aires]., errorContext[NS: ***, PATH: ***, REFERENCE_ID: ***, LINK_CREDIT: ***]



Also in the log, we found this message:

onConnectionLocalClose hostname[***.servicebus.windows.net:5671], connectionId[***], errorCondition[amqp:connection:forced], errorDescription[The connection was inactive for more than the allowed 60000 milliseconds and is closed by container 'LinkTracker'. TrackingId:***, SystemTracker:gateway5, Timestamp:2021-02-25T13:41:04]



It seems that it does not retry to connect immediately when the connection was closed. This error occurs several times a day. Any ideas on how to resolve?


This is the stacktrace:

2021-02-26 06:59:45,382 ERROR [Timer-Driven Process Thread-6] o.a.n.p.azure.eventhub.PutAzureEventHub PutAzureEventHub[id=*****] Failed to send StandardFlowFileRecord[uuid=***,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=***, container=default, section=674], offset=245481, length=1394],offset=0,name=***,size=1394] to EventHub due to java.util.concurrent.CompletionException: com.microsoft.azure.eventhubs.TimeoutException: Entity(***): Send operation timed out at 2021-02-26T06:59:45.382-03:00[America/Argentina/Buenos_Aires]., errorContext[NS: ***, PATH: ***, REFERENCE_ID: ***, LINK_CREDIT: ***]; routing to failure: java.util.concurrent.CompletionException: com.microsoft.azure.eventhubs.TimeoutException: Entity(***): Send operation timed out at 2021-02-26T06:59:45.382-03:00[America/Argentina/Buenos_Aires]., errorContext[NS: ***, PATH: ***, REFERENCE_ID: ***, LINK_CREDIT: ***]
java.util.concurrent.CompletionException: com.microsoft.azure.eventhubs.TimeoutException: Entity(***): Send operation timed out at 2021-02-26T06:59:45.382-03:00[America/Argentina/Buenos_Aires]., errorContext[NS: ***, PATH: ***, REFERENCE_ID: ***, LINK_CREDIT: ***]
at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
at java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
at com.microsoft.azure.eventhubs.impl.ExceptionUtil.completeExceptionally(ExceptionUtil.java:104)
at com.microsoft.azure.eventhubs.impl.MessageSender.throwSenderTimeout(MessageSender.java:900)
at com.microsoft.azure.eventhubs.impl.MessageSender.access$1800(MessageSender.java:40)
at com.microsoft.azure.eventhubs.impl.MessageSender$SendTimeout.run(MessageSender.java:1016)
at com.microsoft.azure.eventhubs.impl.Timer$ScheduledTask.onEvent(Timer.java:49)
at com.microsoft.azure.eventhubs.impl.DispatchHandler.onTimerTask(DispatchHandler.java:9)
at org.apache.qpid.proton.engine.BaseHandler.handle(BaseHandler.java:233)
at org.apache.qpid.proton.engine.impl.EventImpl.dispatch(EventImpl.java:108)
at org.apache.qpid.proton.reactor.impl.ReactorImpl.dispatch(ReactorImpl.java:324)
at org.apache.qpid.proton.reactor.impl.ReactorImpl.process(ReactorImpl.java:291)
at com.microsoft.azure.eventhubs.impl.MessagingFactory$RunReactor.run(MessagingFactory.java:512)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.microsoft.azure.eventhubs.TimeoutException: Entity(***): Send operation timed out at 2021-02-26T06:59:45.382-03:00[America/Argentina/Buenos_Aires]., errorContext[NS: ***, PATH: ***, REFERENCE_ID: ***, LINK_CREDIT: ***]
at com.microsoft.azure.eventhubs.impl.MessageSender.throwSenderTimeout(MessageSender.java:896)
... 16 common frames omitted

Thanks!!