Joe Manjiyil on Mon, 24 Jul 2017 05:16:30
We have a .net cloud service which is consuming from eventhub which has 8 partitions. During the startup and even after a day, we are seeing all the partitions being read and updated correctly. I am checking the last read time from the eventhub storage account. But after 2-3 days I am seeing that one of the partitions is not read. Because of this whatever message is being sent to that partition is not being consumed by the cloud service.
My understanding is that the await _eventProcessorHost.RegisterEventProcessorAsync<EventProcessor>(options); should take care of registering the listeners and load balance among the different partitions.
Is this normal behavior ? should I do something in the cloud service eventprocessorhost code to handle this scenario when certain partitions are not being read.