Skip to content

KafkaStreamsBuilderImpl

KafkaStreamsBuilderImpl is a KafkaStreamsBuilder.

KafkaStreamsBuilderImpl acts as a bridge between ksqlDB and Kafka Streams library.

Creating Instance

KafkaStreamsBuilderImpl takes the following to be created:

KafkaStreamsBuilderImpl is created along with a QueryBuilder.

KafkaClientSupplier

KafkaStreamsBuilderImpl is given a KafkaClientSupplier (Kafka Streams) when created.

Building KafkaStreams Client

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

build creates a KafkaStreams (Kafka Streams) with the given Topology (Kafka Streams) (with the given conf properties and the KafkaClientSupplier).

build is part of the KafkaStreamsBuilder abstraction.

buildNamedTopologyWrapper

KafkaStreamsNamedTopologyWrapper buildNamedTopologyWrapper(
  Map<String, Object> conf)

buildNamedTopologyWrapper creates a KafkaStreamsNamedTopologyWrapper with the given conf properties and the KafkaClientSupplier.

buildNamedTopologyWrapper is part of the KafkaStreamsBuilder abstraction.

Back to top