THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The changes also include adding a setter
method on the KafkaStreams
object:, named setGlobalStateRestoreListener
to reinforce the fact the listener is for the entire application
Code Block | ||
---|---|---|
| ||
public void setStateRestoreListenersetGlobalStateRestoreListener(final StateRestoreListener stateRestoreListener) |
...