THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
// Prefix setter for consumer config public static final String CONSUMER_PREFIX = "consumer."; public static String consumerPrefix(final String consumerProp) { return CONSUMER_PREFIX + consumerProp; } ... // API to get consumer configs public Map<String, Object> getConsumerConfigs(final String groupId, final String clientId); public Map<String, Object> getRestoreConsumerConfigs(final String clientId); |
Code Block | ||||
---|---|---|---|---|
| ||||
// Current KafkaClientSupplier consumer APIs:
Consumer<byte[], byte[]> getConsumer(final Map<String, Object> config);
Consumer<byte[], byte[]> getRestoreConsumer(final Map<String, Object> config); |
...