В концентраторе событий Azure, созданном с 2 разделами, потребитель концентратора событий пытается подключиться к 3-му и 4-му разделам

Question

Я установил концентратор событий Azure с 2 разделами. Я использую опубликованный Microsoft код (https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-java-get-started-send) для получения сообщений из концентратора событий. Потребитель пытается подключиться к 3-му и 4-му разделам, даже если они не существуют.

Сообщение об ошибке:

2019-06-14 09: 34: 34,998 [ault | host] -1-13] - ОШИБКА PartitionPump
- хост хост: 3: не удалось создать PartitionReceiver java.util.concurrent.CompletionException: com.microsoft.azure.eventhubs.EventHubException: указанное раздел недействителен для отправителя или получателя раздела EventHub. Это должно быть между 0 и 1. Имя параметра: PartitionId TrackingId: 11c0c687fa3146ffaa97749d23abeae5_G27, SystemTracker: gateway5, отметка времени: 2019-06-14T04: 04: 34, errorContext [NS: dev-sams-iot.servicebus.windows.net, PATH: test / ConsumerGroups / $ Default / Partitions / 3, REFERENCE_ID: 6d2875_ae5_G27_1560485074529] в java.util.concurrent.CompletableFuture.encodeThrowable (CompletableFuture.java:292) в java.util.concurrent.CompletableFuture.completeThrowable (CompletableFuture.java:308) в java.util.concurrent.CompletableFuture.uniAccept (CompletableFuture.java:647) в java.util.concurrent.CompletableFuture $ UniAccept.tryFire $$$ захвата (CompletableFuture.java:632) в java.util.concurrent.CompletableFuture $ UniAccept.tryFire (CompletableFuture.java) в java.util.concurrent.CompletableFuture.postComplete (CompletableFuture.java:474) в java.util.concurrent.CompletableFuture.completeExceptionally (CompletableFuture.java:1977) в com.microsoft.azure.eventhubs.impl.ExceptionUtil.completeExceptionally (ExceptionUtil.java:104) в com.microsoft.azure.eventhubs.impl.MessageReceiver.cancelOpen (MessageReceiver.java:361) в com.microsoft.azure.eventhubs.impl.MessageReceiver.onOpenComplete (MessageReceiver.java:351) в com.microsoft.azure.eventhubs.impl.MessageReceiver.onError (MessageReceiver.java:418) в com.microsoft.azure.eventhubs.impl.MessageReceiver.onClose (MessageReceiver.java:740) в com.microsoft.azure.eventhubs.impl.BaseLinkHandler.processOnClose (BaseLinkHandler.java:74) в com.microsoft.azure.eventhubs.impl.BaseLinkHandler.handleRemoteLinkClosed (BaseLinkHandler.java:113) в com.microsoft.azure.eventhubs.impl.BaseLinkHandler.onLinkRemoteClose (BaseLinkHandler.java:48) в org.apache.qpid.proton.engine.BaseHandler.handle (BaseHandler.java:176) в 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:507) в java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:511) в java.util.concurrent.FutureTask.run $$$ capture (FutureTask.java:266) в java.util.concurrent.FutureTask.run (FutureTask.java) в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 201 (ScheduledThreadPoolExecutor.java:180) в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:293) в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:624) at java.lang.Thread.run (Thread.java:748)

Answer 1

При создании концентратора событий также необходима учетная запись хранения.Event-hub хранит такие данные, как количество разделов и сообщения о разделах в учетной записи хранения.

Вышесказанное связано с тем, что изначально я создал Event-hub с четырьмя разделами, и сведения о нем были сохранены в учетной записи хранения.,Я удалил этот концентратор событий, а затем создал другой концентратор событий с двумя разделами.Оба концентратора событий использовали одну и ту же учетную запись хранения.Удаление содержимого учетной записи хранения решило проблему.