Skip to content

Latest commit

 

History

History
152 lines (124 loc) · 4.21 KB

kafka-streams-Topology.adoc

File metadata and controls

152 lines (124 loc) · 4.21 KB
Raw

Topology

Topology is…​FIXME

Topology is created when StreamsBuilder is created.

Topology takes no arguments when created.

Topology manages an InternalTopologyBuilder. When created, Topology immediately creates a InternalTopologyBuilder for…​FIXME

kafka streams Topology InternalTopologyBuilder
Figure 1. Topology and InternalTopologyBuilder

Topology can be described, i.e. FIXME + EXAMPLE

addStateStore Method

synchronized Topology addStateStore(
  final StoreBuilder storeBuilder,
  final String... processorNames)

addStateStore…​FIXME

Note
 addStateStore is used when…​FIXME

addSource Method

synchronized Topology addSource(
  final String name,
  final String... topics)
synchronized Topology addSource(
  final AutoOffsetReset offsetReset,
  final String name,
  final String... topics)
synchronized Topology addSource(
  final TimestampExtractor timestampExtractor,
  final String name,
  final String... topics)
synchronized Topology addSource(
  final AutoOffsetReset offsetReset,
  final TimestampExtractor timestampExtractor,
  final String name,
  final String... topics)
synchronized Topology addSource(
  final String name,
  final Deserializer keyDeserializer,
  final Deserializer valueDeserializer,
  final String... topics)
synchronized Topology addSource(
  final AutoOffsetReset offsetReset,
  final String name,
  final Deserializer keyDeserializer,
  final Deserializer valueDeserializer,
  final String... topics)
synchronized Topology addSource(
  final AutoOffsetReset offsetReset,
  final String name,
  final TimestampExtractor timestampExtractor,
  final Deserializer keyDeserializer,
  final Deserializer valueDeserializer,
  final String... topics)

addSource…​FIXME

Note
 addSource is used when…​FIXME

addGlobalStore Method

synchronized Topology addGlobalStore(
  final StoreBuilder storeBuilder,
  final String sourceName,
  final Deserializer keyDeserializer,
  final Deserializer valueDeserializer,
  final String topic,
  final String processorName,
  final ProcessorSupplier stateUpdateSupplier)
synchronized Topology addGlobalStore(
  final StoreBuilder storeBuilder,
  final String sourceName,
  final TimestampExtractor timestampExtractor,
  final Deserializer keyDeserializer,
  final Deserializer valueDeserializer,
  final String topic,
  final String processorName,
  final ProcessorSupplier stateUpdateSupplier)

addGlobalStore…​FIXME

Note
 addGlobalStore is used when…​FIXME

connectProcessorAndStateStores Method

synchronized Topology connectProcessorAndStateStores(
  final String processorName,
  final String... stateStoreNames)

connectProcessorAndStateStores simply requests InternalTopologyBuilder to connectProcessorAndStateStores and returns itself (the Topology being built).

addSink Method

Topology addSink(
  final String name,
  final String topic,
  final String... parentNames)
Topology addSink(
  final String name,
  final String topic,
  final Serializer<K> keySerializer,
  final Serializer<V> valueSerializer,
  final String... parentNames)
Topology addSink(
  final String name,
  final String topic,
  final StreamPartitioner<? super K, ? super V> partitioner,
  final String... parentNames)
Topology addSink(
  final String name,
  final String topic,
  final Serializer<K> keySerializer,
  final Serializer<V> valueSerializer,
  final StreamPartitioner<? super K, ? super V> partitioner,
  final String... parentNames)

addSink…​FIXME

Note
 addSink is used when…​FIXME

Describing Topology — describe Method

TopologyDescription describe()

describe…​FIXME