THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
getClientPropsWithPrefix 276
refactor
getCommonConsumerConfigs() function, to accept prefix. And let developer add prefix easily.
Public Interfaces
Code Block | ||
---|---|---|
| ||
// KafkaClientSupplier consumer APIs: Consumer<byte[], byte[]> getConsumer(final Map<String, Object> config); Consumer<byte[], byte[]> getRestoreConsumer(final Map<String, Object> config); // New API for global consumer: Consumer<byte[], byte[]> getGlobalConsumer(final Map<String, Object> config); |
...