class TrackingEventProcessorManager {

    EventTracker createEventTracker(long trackingToken, String clientId, boolean forceReadingFromLeader,
                                    StreamObserver<InputStream> eventStream) {
        return new EventTracker(trackingToken, clientId, forceReadingFromLeader, eventStream);
    }

    public  TrackingEventProcessorManager(EventStorageEngine eventStorageEngine, int blacklistedSendAfter);
      TrackingEventProcessorManager(String context, Function<Long, CloseableIterator<SerializedEventWithToken>> iteratorBuilder, int blacklistedSendAfter);

}