THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
By rewriting the getRestoreConsumerConfigs() function and adding the getGlobalConsumerConfigs() function, if one user uses restoreConsumerPrefix() or globalConsumerPrefix() when adding new configurations, the configs shall overwrite base consumer config. If not specified, restore consumer and global consumer shall share the same config with base consumer.
Example
: if one user writes:
| Code Block | ||||
|---|---|---|---|---|
| ||||
consumer.max.poll.record = 5
restore-consumer.max.poll.record = 50 |
During initialization, consumers would get:
| consumer type | max.poll.record | Reason |
|---|---|---|
| base consumer | 5 | Target assignment with general "consumer" prefix |
| restore consumer | 50 | Get override config 50 by prefixing "restore-consumer" |
| global consumer | 5 | Since no "global-consumer" prefix is used, share the same config with base. |
Compatibility, Deprecation, and Migration Plan
...