Versions Compared

Old Version 24

changes.mady.by.user Boyang Chen

Saved on

compared with

New Version 25

changes.mady.by.user Boyang Chen

Saved on

Key

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

...

The changes affected classes including `StreamsConfig` and `KafkaClientSupplier` StreamsConfig and KafkaClientSupplier. Existing APIs look like below:

Code Block
languagejava
titleStreamsConfig.java
public static final String CONSUMER_PREFIX = "consumer.";


public Map<String, Object> getConsumerConfigs(final String groupId, final String clientId);
public Map<String, Object> getRestoreConsumerConfigs(final String clientId);

 

Code Block
languagejava
titleKafkaClientSupplier.java
// Current KafkaClientSupplier consumer APIs: 
Consumer<byte[], byte[]> getConsumer(final Map<String, Object> config);
Consumer<byte[], byte[]> getRestoreConsumer(final Map<String, Object> config);

...