Class ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.context.internal.ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory
-
- All Implemented Interfaces:
KafkaStreamsFactory
- Enclosing class:
- ContextAwareKafkaStreamsFactorySupplier
public static class ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory extends Object implements KafkaStreamsFactory
A delegatingKafkaStreamsFactory
which is notConfigurable
.
-
-
Field Summary
-
Fields inherited from interface io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory
DEFAULT
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.kafka.streams.KafkaStreams
make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config.
-
-
-
Method Detail
-
make
public org.apache.kafka.streams.KafkaStreams make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config.- Specified by:
make
in interfaceKafkaStreamsFactory
- Parameters:
topology
- theTopology
instance.streamsConfig
- the streams configuration.- Returns:
- the
KafkaStreams
instance.
-
-