Uses of Interface
io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory
-
-
Uses of KafkaStreamsFactory in io.streamthoughts.azkarra.api
Method parameters in io.streamthoughts.azkarra.api with type arguments of type KafkaStreamsFactory Modifier and Type Method Description StreamsExecutionEnvironment
StreamsExecutionEnvironment. setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> kafkaStreamsFactory)
Sets theKafkaStreamsFactory
that will be used to provide theKafkaStreams
to configure and start. -
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
Methods in io.streamthoughts.azkarra.api.streams with parameters of type KafkaStreamsFactory Modifier and Type Method Description KafkaStreamContainerBuilder
KafkaStreamContainerBuilder. withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
-
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 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()
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 StreamsExecutionEnvironment
DefaultStreamsExecutionEnvironment. setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> kafkaStreamsFactory)
Sets theKafkaStreamsFactory
that will be used to provide theKafkaStreams
to configure and start.
-