Table of Contents |
---|
Status
Current state: Under Discussionreleased in 2.0
Discussion thread: here
JIRA: JIRA 6657
...
Code Block | ||||
---|---|---|---|---|
| ||||
// New API for global consumer: Consumer<byte[], byte[]> getGlobalConsumer(final Map<String, Object> config); |
By rewriting deprecating the getRestoreConsumerConfigs() function getConsumerConfigs function (from now user should use getMainConsumerConfigs instead), rewriting the getRestoreConsumerConfigs function and adding the getGlobalConsumerConfigs() getGlobalConsumerConfigs function, if one user uses restoreConsumerPrefix() or globalConsumerPrefix() when or globalConsumerPrefix when adding new configurations, the configs shall overwrite base consumer config. If one just wants to change main consumer behavior without actually affecting other consumers, using mainConsumerPrefix() mainConsumerPrefix would make sure the change only apply to main consumer. If not specified, main consumer, restore consumer and global consumer shall share the same config with base consumer.
...