Versions Compared

Old Version 48

changes.mady.by.user vitojeng

Saved on

compared with

New Version 49

changes.mady.by.user vitojeng

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The interface QueryableStoreType will append a new method. This can be assigned KafkaStreams instance to all QueryableStoreType instances for checking KafkaStreams state.:

Code Block
languagejava
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
titleCall trace 1: KafkaStreams#store()
  • KafkaStreams#store() (v)
    • QueryableStoreProvider#getStore() (v)
      • GlobalStateStoreProvider#stores() (v)
      • StreamThreadStateStroeProvider#stores() (v)

...