TopologyProvider (Azkarra Framework 0.9.0 API)

All Superinterfaces:

Provider<org.apache.kafka.streams.Topology>, Versioned

All Known Implementing Classes:

BasicWordCountTopology, ComplexWordCountTopology, ConditionalStreamsApplication.NormalizeStreamsTopology, ConfigurableWordCountTopology, ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider, OptimizedTopologyProvider, ServerSentEventExample.WordCountPublisherTopology
```
public interface TopologyProvider
extends Provider<org.apache.kafka.streams.Topology>
```
The default interface to supply a Kafka Streams Topology instance.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`static TopologyProvider`	`of(org.apache.kafka.streams.Topology topology, Version version)`	An helper method to create a static `TopologyProvider` returning the provided `Topology`.
`org.apache.kafka.streams.Topology`	`topology()`	Supplies a new Kafka Streams `Topology` instance.
`String`	`version()`	Returns the version for this `Topology`.

- Method Detail
  - version
```
String version()
```
    Returns the version for this Topology.
    
    Specified by:
    
    version in interface Versioned
    
    Returns:
    
    the string version.
  - topology
```
org.apache.kafka.streams.Topology topology()
```
    Supplies a new Kafka Streams Topology instance.
    
    Specified by:
    
    topology in interface Provider<org.apache.kafka.streams.Topology>
    
    Returns:
    
    the Topology instance.
  - of
```
static TopologyProvider of(org.apache.kafka.streams.Topology topology,
                           Version version)
```
    An helper method to create a static TopologyProvider returning the provided Topology.
    
    Parameters:
    
    topology - the Topology instance.
    
    version - the topology's version.
    
    Returns:
    
    a new TopologyProvider instance.