Class TopologyMetadata
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
-
public class TopologyMetadata extends Object
-
-
Constructor Summary
Constructors Constructor Description TopologyMetadata(String name, String version, String description, org.apache.kafka.streams.TopologyDescription topology, Conf streamsConfig)
Creates a newTopologyMetadata
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
description()
boolean
equals(Object o)
int
hashCode()
String
name()
Conf
streamsConfig()
org.apache.kafka.streams.TopologyDescription
topology()
String
toString()
String
version()
-
-
-
Constructor Detail
-
TopologyMetadata
public TopologyMetadata(String name, String version, String description, org.apache.kafka.streams.TopologyDescription topology, Conf streamsConfig)
Creates a newTopologyMetadata
instance.- Parameters:
name
- the topology name.version
- the topology version.description
- the topology description.topology
- theTopology
instance to used for creating a newKafkaStreams
.streamsConfig
- theConf
instance to used for creating a newKafkaStreams
.
-
-