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!!
