THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Implementing the new rebalance protocol in the current group coordinator is not appropriate in our opinion because its requires many changes anyway in the current protocol to make it interoperable. Therefore, this KIP proposes to rewrite the group coordinator from scratch in Java. The new group coordinator will have a replicated state machine per __consumer_offsets partitions, where each replicated state machine is modelled as an event loop. Those replicated state machines will be executed in group.coordinator.threads threads.
...
| Name | Type | Default | Doc |
|---|---|---|---|
| group.coordinator.threads | int | 1 | The number of threads used to run the state machines. |
| group.consumer.session.timeout.ms | int | 30s45s | The timeout to detect client failures when using the consumer group protocol. |
| group.consumer.min.session.timeout.ms | int | 45s | The minimum session timeout. |
| group.consumer.max.session.timeout.ms | int | 60s | The maximum session timeout. |
| group.consumer.heartbeat.interval.ms | int | 5s | The heartbeat interval given to the members. |
| group.consumer.min.heartbeat.interval.ms | int | 5s | The minimum heartbeat interval. |
| group.consumer.max.heartbeat.interval.ms | int | 15s | The maximum heartbeat interval. |
| group.consumer.max.size | int | MaxValue | The maximum number of consumers that a single consumer group can accommodate. |
| group.consumer.assignors | List | range, uniform | The server side assignors. |
...
| Name | Type | Default | Doc |
|---|---|---|---|
| group.consumer.session.timeout.ms | int | 30s45s | The timeout to detect client failures when using the consumer group protocol. |
| group.consumer.heartbeat.interval.ms | int | 5s | The heartbeat interval given to the members. |
...