Aggregates values by key into a new KTable.

Returns a list of KStreams, one for each of the `predicate-fns`
provided.

Stops the kafka streams.

Counts the number of records by key into a new KTable.

Creates a KStream that consists of all elements that do not satisfy a
predicate.

Creates a KStream that will consist of the concatenation of messages
returned by calling `key-value-mapper-fn` on each key/value pair in the
input stream.

Creates a KStream that will consist of the concatenation of the values
returned by calling `value-mapper-fn` on each value in the input stream.

Performs an action on each element of KStream.

Creates a GlobalKTable that will consist of data from the specified
topic.

Returns the underlying GlobalKTable

Groups the records of this KStream/KTable using the key-value-mapper-fn.

Groups records with the same key into a KGroupedStream.

Combines the values of the two KTables that share the same key using an
inner join.

Combines the values of two streams that share the same key using a
windowed inner join.

Makes a Kafka Streams object.

Returns the underlying KGroupedStream object.

Returns the underlying KGroupedTable object.

Creates a KStream that will consume messages from the specified topic.

Returns the underlying KStream object.

Creates a KStream that will consume messages from the specified topics.

Creates a KTable that will consist of data from the specified topic.

Returns the underlying KTable object.

Creates a KStream from the result of calling `value-joiner-fn` with
each element in the KStream and the value in the KTable with the same
key.

Combines the values of two streams that share the same key using a
windowed left join.

Creates a KStream that consists of the result of applying
`key-value-mapper-fn` to each key/value pair in the input stream.

Creates a KStream that is the result of calling `value-mapper-fn` on each
element of the input stream.

Combines the values of two KTables that share the same key using an outer
join.

Combines the values of two streams that share the same key using a
windowed outer join.

Performs the action defined by `peek-fn` on each element of the input
KStream, returning that stream untransformed.

Prints the elements of the stream to *out*.

Applies `processor-fn` to each item in the input stream.

Combines values of a stream by key into a new KTable.

Create a new key from the current key and value.

`select-key-value-mapper-fn` should be a function that takes a key-value
pair, and returns the value of the new key. Here is example multiplies each
key by 10:

```(fn [[k v]] (* 10 k))```

Gets the names of source topics for the topology.

Starts processing.

Returns the underlying KStreamBuilder.

Materializes a stream to a topic, and returns a new KStream that will
consume messages from the topic.

Materializes a stream to a topic.

Converts a KTable to a KStream.

Creates a KStream that consists of the results of applying the transformer
to each key/value in the input stream.

Creates a KStream that consists of the results of applying the transformer
to each value in the input stream.

Windows the KStream

Windows the KStream