Versions Compared

Old Version 15

changes.mady.by.user Boyang Chen

Saved on

compared with

New Version 16

changes.mady.by.user Boyang Chen

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

We might also consider to extend `KafkaClientSupplier` and add a `getGlobalConsumer()` method.

 

Look at StreamsConfig#786 for 

getConsumerConfigs function

Public Interfaces

Code Block
languagejava
// 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);

...