THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Is there a better way to configure session interval and heartbeat interval?
Consumer API Internal Changes
...
Changes
Assign
- The polling thread updates the subscriptionState.
- Create an ASSIGN event, and queue up the event to the background thread.
- Background thread receives the event and executes the event.
- send a commitOffset
- Update metadata
Subscribe
- The polling thread updates the subscriptionState.
- Create a SUBSCRIBE event, and send it to the background thread.
- Background thread executes the event:
- Update metadata
Poll
- Poll the ConsumerEventQueue, and execute the events accordingly
- Prepare a FETCH event, and send it to the background thread.
- Wait for the CompleteableFuture to finish
- Execute the interceptor.onConsumer and return the data.
- Background thread execute the FETCH event:
- poll coordinator
- issue fetch requests
Event Data Models
ConsumerEvent | ||
Name | Type | Description |
---|---|---|
type | ConsumerEventType | Type of event |
requiredCoordinator | bool | Indicate if the event uses coordinator |
ServerEvent | ||
type | ServerEventType | Type of event |
...