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:

• KafkaClientSupplier

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.