Class DefaultContainerIdBuilder
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
-
- All Implemented Interfaces:
ContainerIdBuilder
public class DefaultContainerIdBuilder extends Object implements ContainerIdBuilder
-
-
Field Summary
Fields Modifier and Type Field Description static String
CONTAINER_ID_CONFIG
-
Constructor Summary
Constructors Constructor Description DefaultContainerIdBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ContainerId
buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.
-
-
-
Field Detail
-
CONTAINER_ID_CONFIG
public static final String CONTAINER_ID_CONFIG
- See Also:
- Constant Field Values
-
-
Method Detail
-
buildContainerId
public ContainerId buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.- Specified by:
buildContainerId
in interfaceContainerIdBuilder
metadata
- the topology's metadata.config
- the topology's configuration.- Returns:
- a new
ContainerId
instance.
-
-