Uses of Interface
io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory
-
-
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.api
Fields in io.streamthoughts.azkarra.api with type parameters of type KafkaStreamsFactory Modifier and Type Field Description protected Supplier<KafkaStreamsFactory>
Executed. factory
Method parameters in io.streamthoughts.azkarra.api with type arguments of type KafkaStreamsFactory Modifier and Type Method Description Executed
Executed. withKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory)
Returns a newExecuted
with the specifiedKafkaStreams
factory. -
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.api.streams
Fields in io.streamthoughts.azkarra.api.streams declared as KafkaStreamsFactory Modifier and Type Field Description static KafkaStreamsFactory
KafkaStreamsFactory. DEFAULT
-
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.runtime.context.internal
Classes in io.streamthoughts.azkarra.runtime.context.internal that implement KafkaStreamsFactory Modifier and Type Class Description class
ClassLoaderAwareKafkaStreamsFactory
static class
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory
A delegatingKafkaStreamsFactory
which is notConfigurable
.Methods in io.streamthoughts.azkarra.runtime.context.internal that return KafkaStreamsFactory Modifier and Type Method Description KafkaStreamsFactory
ContextAwareKafkaStreamsFactorySupplier. get()
Constructors in io.streamthoughts.azkarra.runtime.context.internal with parameters of type KafkaStreamsFactory Constructor Description ClassLoaderAwareKafkaStreamsFactory(KafkaStreamsFactory delegate, ClassLoader classLoader)
Creates a newClassLoaderAwareKafkaStreamsFactory
instance.Constructor parameters in io.streamthoughts.azkarra.runtime.context.internal with type arguments of type KafkaStreamsFactory Constructor Description ContextAwareKafkaStreamsFactorySupplier(AzkarraContext context, GettableComponent<KafkaStreamsFactory> gettable)
-
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.runtime.env
Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type KafkaStreamsFactory Modifier and Type Method Description LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory)
Sets theKafkaStreamsFactory
that will be used to provide theKafkaStreams
to configure and start. -
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.runtime.streams
Fields in io.streamthoughts.azkarra.runtime.streams declared as KafkaStreamsFactory Modifier and Type Field Description protected KafkaStreamsFactory
LocalKafkaStreamsContainer. streamsFactory
Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type KafkaStreamsFactory Modifier and Type Method Description LocalKafkaStreamsContainerBuilder
LocalKafkaStreamsContainerBuilder. withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
-
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.runtime.streams.topology
Methods in io.streamthoughts.azkarra.runtime.streams.topology that return types with arguments of type KafkaStreamsFactory Modifier and Type Method Description Optional<Supplier<KafkaStreamsFactory>>
InternalExecuted. factory()
-