Class KafkaStreamsInstance
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.KafkaStreamsInstance
-
-
Constructor Summary
Constructors Constructor Description KafkaStreamsInstance(String id, Endpoint endpoint, boolean isLocal, KafkaStreamsMetadata metadata)
Creates a newKafkaStreamsInstance
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Endpoint
endpoint()
String
id()
boolean
isLocal()
KafkaStreamsMetadata
metadata()
-
-
-
Constructor Detail
-
KafkaStreamsInstance
public KafkaStreamsInstance(String id, Endpoint endpoint, boolean isLocal, KafkaStreamsMetadata metadata)
Creates a newKafkaStreamsInstance
instance.- Parameters:
id
- the identifier for this instance, i.e. the container id.endpoint
- the endpoint for this instance.isLocal
- a flag to indicate if this instance is running locally.metadata
- the metadata for this instance.
-
-
Method Detail
-
endpoint
public Endpoint endpoint()
-
isLocal
public boolean isLocal()
-
metadata
public KafkaStreamsMetadata metadata()
-
-