THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
A new reset policy(s) will be added which will allow the user some flexibility in determining the resilience of GlobalStreamThread. It should also be noted that Topology.addGlobalStore does not allow the user to decide which policy to use. This method will potentially have to be extended.
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
public class Topology {
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
TBD. The details of the new reset policy is yet to be decided upon.
...