KafkaStreamsBuilder¶

KafkaStreamsBuilder is an abstraction of KafkaStreams builders.

Contract¶

Building KafkaStreams Client¶

KafkaStreams build(
  Topology topology,
  Map<String, Object> conf)

KafkaStreamsBuilderImpl

Used when:

• QueryMetadataImpl is requested to initialize

buildNamedTopologyWrapper¶

KafkaStreamsNamedTopologyWrapper buildNamedTopologyWrapper(
  Map<String, Object> conf)

KafkaStreamsBuilderImpl

Used when:

• SharedKafkaStreamsRuntime is created
• SharedKafkaStreamsRuntimeImpl is requested to restartStreamsRuntime

Implementations¶

• KafkaStreamsBuilderImpl