THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The interface QueryableStoreType will append a new method, this . This can be assign assigned KafkaStreams instance to all ComposeReadOnlyXXXXStore instance for checking KafkaStreams instance state.
| Code Block | ||
|---|---|---|
| ||
public interface QueryableStoreType<T> {
void setStreams(final KafkaStreams kafkaStreamsstreams);
} |
...
The following is the public method that users will call:
...