THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The interface QueryableStoreType will append a new method. This can be assigned KafkaStreams instance to all QueryableStoreType instances for checking KafkaStreams state.:
Code Block | ||
---|---|---|
| ||
public interface QueryableStoreType<T> { void setStreams(final KafkaStreams streams); } |
This can be assigned KafkaStreams instance to all QueryableStoreType instances for checking KafkaStreams state.
Call Trace
Expand | ||
---|---|---|
| ||
|
...