THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
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 ofaddGlobalStore
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.
...