ChangeFeedProcessor (Azure SDK for Java Reference Documentation)

```
public interface ChangeFeedProcessor
```
Simple host for distributing change feed events across observers and thus allowing these observers scale. It distributes the load across its instances and allows dynamic scaling: - Partitions in partitioned collections are distributed across instances/observers. - New instance takes leases from existing instances to make distribution equal. - If an instance dies, the leases are distributed across remaining instances. It's useful for scenario when partition count is high so that one host/VM is not capable of processing that many change feed events. Client application needs to implement ChangeFeedObserver and register processor implementation with ChangeFeedProcessor.
It uses auxiliary document collection for managing leases for a partition. Every EventProcessorHost instance is performing the following two tasks: 1) Renew Leases: It keeps track of leases currently owned by the host and continuously keeps on renewing the leases. 2) Acquire Leases: Each instance continuously polls all leases to check if there are any leases it should acquire for the system to get into balanced state.

Nested Classes
Modifier and Type	Interface and Description
`static interface`	`ChangeFeedProcessor.BuilderDefinition` The `ChangeFeedProcessor` changeFeedProcessorBuilder definitions for setting the properties.

All Methods Static Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`static ChangeFeedProcessor.BuilderDefinition`	`changeFeedProcessorBuilder()` Helper static method to buildAsyncClient `ChangeFeedProcessor` instances as logical representation of the Azure Cosmos DB database service.
`reactor.core.publisher.Mono<Void>`	`start()` Start listening for changes asynchronously.
`reactor.core.publisher.Mono<Void>`	`stop()` Stops listening for changes asynchronously.

Interface ChangeFeedProcessor