...

1. Poll the ConsumerEventQueue, and execute the events accordingly
2. Prepare a FETCH event, and send it to the background thread.
3. Wait for the CompleteableFuture to finish
4. Execute the interceptor.onConsumer and return the data.
5. Background thread execute the FETCH event:
   
   1. Autocommits // I think we can move the autocommit to the background thread
   2. issue fetch requests

Event Data Models

...