Interface StreamManager

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
LogStreamManager

public interface StreamManager extends AutoCloseable
Gives access to StreamProcessor and appender for source provider.
Since:
11.1
  • Method Details

    • register

      void register(String processorName, Topology topology, Settings settings)
      Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.
    • createStreamProcessor

      StreamProcessor createStreamProcessor(String processorName)
      Creates a registered processor without starting it.
    • registerAndCreateProcessor

      default StreamProcessor registerAndCreateProcessor(String processorName, Topology topology, Settings settings)
      Registers and creates a processor without starting it.
    • register

      void register(List<String> streams, Settings settings)
      Registers some source Streams without any processors.
      Since:
      11.4
    • append

      LogOffset append(String stream, Record record)
      Appends a record to a processor's source stream.
    • getProcessorNames

      Set<String> getProcessorNames()
      Gets a set of processor names.
      Since:
      2021.25
    • getProcessor

      StreamProcessor getProcessor(String processorName)
      Gets a processor.
      Returns:
      null if the processor doesn't exist
      Since:
      2021.25
    • close

      void close()
      Specified by:
      close in interface AutoCloseable