Class ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware<ApplicationIdBuilder>
-
- io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder
-
- All Implemented Interfaces:
ApplicationIdBuilder
,StreamsExecutionEnvironmentAware
- Enclosing class:
- ContextAwareApplicationIdBuilderSupplier
public static class ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder extends DelegatingExecutionEnvironmentAware<ApplicationIdBuilder> implements ApplicationIdBuilder
A delegatingKafkaStreamsFactory
which is notConfigurable
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ApplicationId
buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.-
Methods inherited from class io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware
setExecutionEnvironment
-
-
-
-
Method Detail
-
buildApplicationId
public ApplicationId buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.- Specified by:
buildApplicationId
in interfaceApplicationIdBuilder
- Parameters:
metadata
- the topology's metadata.streamsConfig
- the topology's configuration.- Returns:
- a new
ApplicationId
instance.
-
-