KafkaStreamsBuilderImpl is a KafkaStreamsBuilder.
KafkaStreamsBuilderImpl acts as a bridge between ksqlDB and Kafka Streams library.
KafkaStreamsBuilderImpl takes the following to be created:
KafkaStreamsBuilderImpl is created along with a QueryBuilder.
Building KafkaStreams Client¶
KafkaStreams build( Topology topology, Map<String, Object> conf)
build is part of the KafkaStreamsBuilder abstraction.
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.