THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
getClientPropsWithPrefix 907
getClientPropsWithPrefix 276
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); |
...