Interface ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>

Type Parameters:
C - Container type
E - Endpoint type
All Known Subinterfaces:
PulsarReaderContainerFactory
All Known Implementing Classes:
AbstractPulsarReaderContainerFactory, DefaultPulsarReaderContainerFactory

public interface ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>
Base container factory interface for PulsarMessageReaderContainer.
Author:
Soby Chacko
  • Method Details

    • createReaderContainer

      C createReaderContainer(E endpoint)
    • createReaderContainer

      C createReaderContainer(String... topics)