THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
// KafkaClientSupplier APIconsumer 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); |
...