Azure / azure-event-hubs-java

☁️ Java client library for Azure Event Hubs
https://azure.microsoft.com/services/event-hubs
MIT License
51 stars 61 forks source link

Load balancing for event processor failed #468

Closed lindsve closed 4 years ago

lindsve commented 4 years ago

This is the code that sets up our event processor clients:

eventProcessorClient = new EventProcessorClientBuilder()
                .connectionString(eventHubConnectionString, getChannelName())
                .processEvent(this::ProcessEvent)
                .processError(this::ProcessError)
                .consumerGroup(consumerGroup)
                .checkpointStore(new BlobCheckpointStore(blobContainerAsyncClient))
                .buildEventProcessorClient();

Actual Behavior

  1. We keep seeing these errors in our logs in our subscriber modules: Load balancing for event processor failed - Did not observe any item or terminal signal within 60000ms in 'filter' (and no fallback has been configured) Did not observe any item or terminal signal within 60000ms in 'filter' (and no fallback has been configured).
  2. We send just a few messages per second, but there should never be such a long period without messages sent from our publisher

Expected Behavior

  1. No such error messages in our logs

Versions