Interface StreamsLifecycleContext

    • Method Detail

      • getApplicationId

        String getApplicationId()
        Gets the application identifier of the current streams instance.
        Returns:
        the application id.
      • getTopology

        org.apache.kafka.streams.TopologyDescription getTopology()
        Gets the topology description of the current streams instance.
        Returns:
        the TopologyDescription instance.
      • getStreamConfig

        Conf getStreamConfig()
        Gets the configuration of the current streams instance.
        Returns:
        the Conf instance.
      • getState

        State getState()
        Gets the state of the current streams instance.
        Returns:
        the State.
      • setState

        void setState​(State state)
        Sets the state of the current streams instance.
        Parameters:
        state - the new State.