Versions Compared

Key

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

...

Code Block
languagejava
titleToplogy.java
public class Topology { 

	// newly added
    public synchronized <K, V> Topology addGlobalStore(final AutoOffsetReset offsetReset,
													   final StoreBuilder<?> storeBuilder,
                                                       final String sourceName,
                                                       final TimestampExtractor timestampExtractor,
                                                       final Deserializer<K> keyDeserializer,
                                                       final Deserializer<V> valueDeserializer,
                                                       final String topic,
                                                       final String processorName,
                                                       final ProcessorSupplier<K, V> stateUpdateSupplier) {
    }
}


Proposed Changes

...

  • Use a new config- global.auto.offset.reset to set reset policy for global stream thread or use the existing one- auto.offset.reset to reset in both StreamThread and GlobalStreamThread.

Compatibility, Deprecation, and Migration Plan

  • The current Topology.addGlobalStore method will most likely be extended. One option We will be adding add a second version of addGlobalStore with extra input parameters while the original method calls the added method with default values. This would not force the user to change their preexisting code in any way.

...