Uses of Class
io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
-
-
Uses of TopologyMetadata in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return TopologyMetadata Modifier and Type Method Description TopologyMetadata
KafkaStreamsContainer. topologyMetadata()
Gets theTopologyMetadata
about the topology runs by thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.api.streams with parameters of type TopologyMetadata Modifier and Type Method Description ApplicationId
ApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf config)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. -
Uses of TopologyMetadata in io.streamthoughts.azkarra.runtime.context.internal
Methods in io.streamthoughts.azkarra.runtime.context.internal with parameters of type TopologyMetadata Modifier and Type Method Description ApplicationId
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. -
Uses of TopologyMetadata in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env with parameters of type TopologyMetadata Modifier and Type Method Description ContainerId
ContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology. -
Uses of TopologyMetadata in io.streamthoughts.azkarra.runtime.env.internal
Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type TopologyMetadata Modifier and Type Method Description ContainerId
DefaultContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology. -
Uses of TopologyMetadata in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return TopologyMetadata Modifier and Type Method Description TopologyMetadata
LocalKafkaStreamsContainer. topologyMetadata()
Gets theTopologyMetadata
about the topology runs by thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type TopologyMetadata Modifier and Type Method Description ApplicationId
DefaultApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.
-